Implementation Of Firebase Cloud Messaging in Spring Server To Push Notification

<dependency>
	<groupId>org.springframework.boot</groupId>
	<artifactId>spring-boot-starter-web</artifactId>
</dependency>
 
<dependency>
	<groupId>org.json</groupId>
	<artifactId>json</artifactId>
	<version>20160810</version>
</dependency>

Step 3:- Now, Create an interceptor Service to push notification from API to the mobile device  : -

package com.firebase.service;

import java.io.IOException;

import org.springframework.http.HttpRequest;
import org.springframework.http.client.ClientHttpRequestExecution;
import org.springframework.http.client.ClientHttpRequestInterceptor;
import org.springframework.http.client.ClientHttpResponse;
import org.springframework.http.client.support.HttpRequestWrapper;
 
public class HeaderRequestInterceptor implements ClientHttpRequestInterceptor {
 
	private final String headerName;
	private final String headerValue;
 
	public HeaderRequestInterceptor(String headerName, String headerValue) {
		this.headerName = headerName;
		this.headerValue = headerValue;
	}
 
	@Override
	public ClientHttpResponse intercept(HttpRequest request, byte[] body, ClientHttpRequestExecution execution)
			throws IOException {
		HttpRequest wrapper = new HttpRequestWrapper(request);
		wrapper.getHeaders().set(headerName, headerValue);
		return execution.execute(wrapper, body);
	}
}

package com.firebase.controller;

import java.io.IOException;

import org.json.JSONException;
import org.json.JSONObject;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.http.HttpEntity;
import org.springframework.http.HttpStatus;
import org.springframework.http.ResponseEntity;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestMethod;
import org.springframework.web.bind.annotation.RestController;

@RestController
public class WebController {

	private final String TOPIC = "Ezbitex Exchange";

	@Autowired
	com.firebase.service.AndroidPushNotificationsService androidPushNotificationsService;

	@RequestMapping(value = "/send", method = RequestMethod.GET, produces = "application/json")
	public ResponseEntity<String> send() throws JSONException {

		JSONObject body = new JSONObject();
		body.put("to", "/topics/" + TOPIC);
		body.put("priority", "high");

		JSONObject notification = new JSONObject();
		notification.put("title", "Ezbitex");
		notification.put("body", "Welcome to Ezbitex Exchange!");

		JSONObject data = new JSONObject();
		data.put("Key-1", "JSA Data 1");
		data.put("Key-2", "JSA Data 2");

		body.put("notification", notification);
		body.put("data", data);

		/**
		 * { "notification": { "title": "JSA Notification", "body": "Happy Message!" },
		 * "data": { "Key-1": "JSA Data 1", "Key-2": "JSA Data 2" }, "to":
		 * "/topics/JavaSampleApproach", "priority": "high" }
		 */

		HttpEntity<String> request = new HttpEntity<>(body.toString());
		String deviceToken = "ecvVeSTNZkE:APA91bGZmJD5drrxoVWl_6ZyYN32Hjy27K22X2mADN3gYrks6xW9aMmjNFuSOiJ9ViEgySz2imwyMjme4Lclcs5-TgQiMjR2Y_SNzyIhNhwe8nvkuJlNHJQqsGfASvX6nv4mrfY8csix";
		try {
			String pushNotification = androidPushNotificationsService.sendPushNotification(deviceToken, "Hello dude",
					"welcome to Ezbitex exchange");

			return new ResponseEntity<>(pushNotification, HttpStatus.OK);
		} catch (IOException e) {
		}
		return new ResponseEntity<>("Push Notification ERROR!", HttpStatus.BAD_REQUEST);
	}
}