Enable Notifications

Copied//Get instance of NotificationOperations Class
NotificationOperations notificationOperations = new NotificationOperations();

//Get instance of BodyWrapper Class that will contain the request body
BodyWrapper bodyWrapper = new BodyWrapper();

//List of Notification instances
List < com.zoho.crm.api.notification.Notification > notifications = new ArrayList < com.zoho.crm.api.notification.Notification > ();

//Get instance of Notification Class
com.zoho.crm.api.notification.Notification notification = new com.zoho.crm.api.notification.Notification();

//Set channel Id of the Notification
notification.setChannelId(100000006800211 l);

List < String > events = new ArrayList < String > ();

events.add("Deals.all");

//To subscribe based on particular operations on given modules.
notification.setEvents(events);

//To set the expiry time for instant notifications. 
notification.setChannelExpiry(OffsetDateTime.of(2020, 05, 20, 10, 00, 00, 01, ZoneOffset.of("+05:30")));

//To ensure that the notification is sent from Zoho CRM, by sending back the given value in notification URL body.
//By using this value, user can validate the notifications.
notification.setToken("TOKEN_FOR_VERIFICATION_OF_1000000068002");

//URL to be notified (POST request)
notification.setNotifyUrl("https://www.zohoapis.com");

//Add Notification instance to the list
notifications.add(notification);

//Get instance of Notification Class
com.zoho.crm.api.notification.Notification notification2 = new com.zoho.crm.api.notification.Notification();

//Set channel Id of the Notification
notification2.setChannelId(100000006800211 l);

List < String > events2 = new ArrayList < String > ();

events2.add("Accounts.all");

//To subscribe based on particular operations on given modules.
notification2.setEvents(events2);

//To set the expiry time for instant notifications. 
notification2.setChannelExpiry(OffsetDateTime.of(2020, 05, 20, 10, 00, 00, 01, ZoneOffset.of("+05:30")));

//To ensure that the notification is sent from Zoho CRM, by sending back the given value in notification URL body.
//By using this value, user can validate the notifications.
notification2.setToken("TOKEN_FOR_VERIFICATION_OF_1000000068002");

//URL to be notified (POST request)
notification2.setNotifyUrl("https://www.zohoapis.com");

//Add Notification instance to the list
notifications.add(notification2);

//Set the list to notifications in BodyWrapper instance
bodyWrapper.setWatch(notifications);

//Call enableNotifications method that takes BodyWrapper instance as parameter 
APIResponse < ActionHandler > response = notificationOperations.enableNotifications(bodyWrapper);

Copiedpackage com.zoho.crm.api.sample.restapi.notifications;
import javax.net.ssl.SSLContext;
import org.apache.http.HttpEntity;
import org.apache.http.HttpResponse;
import org.apache.http.client.methods.HttpEntityEnclosingRequestBase;
import org.apache.http.client.methods.HttpPost;
import org.apache.http.client.methods.HttpUriRequest;
import org.apache.http.client.utils.URIBuilder;
import org.apache.http.conn.ssl.NoopHostnameVerifier;
import org.apache.http.conn.ssl.SSLConnectionSocketFactory;
import org.apache.http.entity.StringEntity;
import org.apache.http.impl.client.CloseableHttpClient;
import org.apache.http.impl.client.HttpClientBuilder;
import org.apache.http.protocol.HTTP;
import org.apache.http.util.EntityUtils;
import org.json.JSONArray;
import org.json.JSONObject;
public class EnableNotifications 
{
	@SuppressWarnings("deprecation")
	public static void main(String[] args) 
	{	
		try
		{
			HttpClientBuilder httpClientBuilder = HttpClientBuilder.create();
			SSLContext sslContext = SSLContext.getDefault();
			SSLConnectionSocketFactory sslConnectionSocketFactory = new SSLConnectionSocketFactory(sslContext, NoopHostnameVerifier.INSTANCE);
			CloseableHttpClient httpclient = httpClientBuilder.setSSLSocketFactory(sslConnectionSocketFactory).build();
			URIBuilder uriBuilder = new URIBuilder("https://www.zohoapis.com/crm/v2.1/actions/watch");
			HttpUriRequest requestObj = new HttpPost(uriBuilder.build());
			HttpEntityEnclosingRequestBase requestBase = (HttpEntityEnclosingRequestBase) requestObj;
			JSONObject requestBody = new JSONObject();
			JSONArray recordArray = new JSONArray();
			JSONObject recordObject = new JSONObject();
			recordObject.put("channel_id", "10068001");
			JSONArray events = new JSONArray();
			events.put("Solutions.create");
			events.put("Price_Books.create");
			events.put("Contacts.create");
			events.put("Solutions.edit");
			recordObject.put("events", events);
			recordObject.put("channel_expiry", "2020-11-02T10:30:00+05:30");
			recordObject.put("token", "TOKEN_FOR_VERIFICATION_OF_10068001");
			recordObject.put("notify_url", "https://www.zoho.com/callback?authorization=Zoho-oauthtoken 1000.23dnsbbbh455jnn&key1=val1&key2=val2");
			recordArray.put(recordObject);
			recordObject = new JSONObject();
			recordObject.put("channel_id", "10068002");
			events = new JSONArray();
			events.put("Deals.all");
			recordObject.put("events", events);
			recordObject.put("channel_expiry", "2020-11-03T10:30:00+05:30");
			recordObject.put("token", "TOKEN_FOR_VERIFICATION_OF_10068002");
			recordObject.put("notify_url", "https://www.zoho.com/callback?authorization=Zoho-oauthtoken 1000.23dnsbbbh455jnn&key1=val1&key2=val2&key3=val1");
			recordArray.put(recordObject);
			recordObject = new JSONObject();
			recordObject.put("channel_id", "10068003");
			events = new JSONArray();
			events.put("Cases.all");
			recordObject.put("events", events);
			recordObject.put("channel_expiry", "2020-11-04T10:30:00+05:30");
			recordObject.put("token", "TOKEN_FOR_VERIFICATION_OF_10068003");
			recordObject.put("notify_url", "https://www.zoho.com/callback?authorization=Zoho-oauthtoken 1000.23dnsbbbh455jnn&key1=val1");
			recordArray.put(recordObject);
			requestBody.put("watch", recordArray);
			requestBase.setEntity(new StringEntity(requestBody.toString(), HTTP.UTF_8));
			requestObj.addHeader("Authorization", "Zoho-oauthtoken 1000.xxxxxxx.xxxxxxx");
			HttpResponse response = httpclient.execute(requestObj);
			HttpEntity responseEntity = response.getEntity();
			System.out.println("HTTP Status Code : " + response.getStatusLine().getStatusCode());
			if(responseEntity != null)
			{
				Object responseObject = EntityUtils.toString(responseEntity);
				String responseString = responseObject.toString();
				System.out.println(responseString);
			}
		}
		catch(Exception ex)
		{
			ex.printStackTrace();
		}
	}
}