Push event notification

The following example shows you how to use push event notifications to get new mail notification.
import java.io.BufferedInputStream;
import java.io.BufferedOutputStream;
import java.io.BufferedReader;
import java.io.ByteArrayInputStream;
import java.io.ByteArrayOutputStream;
import java.io.IOException;
import java.io.InputStreamReader;
import java.net.ServerSocket;
import java.net.Socket;
import java.net.SocketException;
import java.nio.ByteBuffer;
import java.nio.charset.Charset;
import java.text.ParseException;

import javax.xml.stream.XMLStreamException;

import com.independentsoft.exchange.EventType;
import com.independentsoft.exchange.ItemId;
import com.independentsoft.exchange.Message;
import com.independentsoft.exchange.NewMailEvent;
import com.independentsoft.exchange.Notification;
import com.independentsoft.exchange.PushSubscription;
import com.independentsoft.exchange.SendNotificationResponse;
import com.independentsoft.exchange.Service;
import com.independentsoft.exchange.ServiceException;
import com.independentsoft.exchange.StandardFolder;
import com.independentsoft.exchange.StatusEvent;
import com.independentsoft.exchange.SubscribeResponse;
import com.independentsoft.exchange.SubscriptionStatus;

public class Example {

	private static Service service = null;
	
    public static void main(String[] args)
    {
        try
        {    	        
        	service = new Service("https://myserver/ews/Exchange.asmx", "username", "password");            
        	
            //the client computer will listen on port 1234 (see method listen())
            PushSubscription subscription = new PushSubscription(StandardFolder.INBOX, EventType.NEW_MAIL, "http://192.168.2.100:1234"); //IP and port of local client
            SubscribeResponse subscribeResponse = service.subscribe(subscription);

            listen();
        }
        catch (ServiceException e)
        {
            System.out.println(e.getMessage());
            System.out.println(e.getXmlMessage());
            System.out.println(e.getFaultString());

            e.printStackTrace();
        }
        catch (Exception e)
        {
            System.out.println(e.getMessage());
            e.printStackTrace();
        }
    }
    

    public static void listen() throws IOException, ServiceException, XMLStreamException, ParseException
    {
    	System.out.println("Listen ...");

    	Charset charset = Charset.forName("UTF8");
    	
        try
        {     
        	ServerSocket serverSocket = new ServerSocket(1234);

            while (true)
            {
            	Socket socket = serverSocket.accept();
            	
                BufferedInputStream in = new BufferedInputStream(socket.getInputStream());
            
                ByteArrayOutputStream memoryStream = new ByteArrayOutputStream();
                boolean isComplete = false;

                while (!isComplete)
                {
                    byte[] buffer = new byte[16384];
                    int bytesReceived = in.read(buffer);
                    
                    memoryStream.write(buffer, 0, bytesReceived);

                    isComplete = isCompleteRequestReceived(memoryStream.toByteArray());
                }
                
                //Send OK response
                String okResponse = service.sendNotificationResult(SubscriptionStatus.OK); //to unsubscribe use SubscriptionStatus.Unsubscribe
                ByteBuffer responseByteBuffer = charset.encode(okResponse);
                byte[] responseBuffer = new byte[responseByteBuffer.limit()];
                
                System.arraycopy(responseByteBuffer.array(), 0, responseBuffer, 0, responseBuffer.length);

                BufferedOutputStream out = new BufferedOutputStream(socket.getOutputStream());
                
                out.write(responseBuffer, 0, responseBuffer.length);
                out.close();

                //Process received notification
                byte[] receivedBuffer = memoryStream.toByteArray();

                SendNotificationResponse response = service.parseSendNotificationResponse(receivedBuffer);

                if (response != null)
                {
                    Notification notification = response.getNotification();

                    for (int i = 0; i < notification.getEvents().size(); i++)
                    {
                    	System.out.println("SubscriptionId: " + notification.getSubscriptionId());

                        if (notification.getEvents().get(i) instanceof NewMailEvent)
                        {
                            NewMailEvent newMailEvent = (NewMailEvent)notification.getEvents().get(i);

                            ItemId itemId = (ItemId)newMailEvent.getId();

                            Message message = service.getMessage(itemId);

                            System.out.println("ItemId: " + message.getItemId());
                            System.out.println("Subject: " + message.getSubject());
                            System.out.println("ReceivedTime: " + message.getReceivedTime());
                        }
                        else if (notification.getEvents().get(i) instanceof StatusEvent)
                        {
                            StatusEvent statusEvent = (StatusEvent)notification.getEvents().get(i);

                            System.out.println("I'm alive. Watermark: " + statusEvent.getWatermark());
                        }
                    }
                }
            }
        }
        catch (SocketException se)
        {
        	 System.out.println(se.getMessage());
        }
    }

    private static boolean isCompleteRequestReceived(byte[] buffer) throws NumberFormatException, IOException
    {  	
    	Charset charset = Charset.forName("UTF8");
    	
    	String request = charset.decode(ByteBuffer.wrap(buffer)).toString();
    	
        int bodyIndex = request.indexOf("\r\n\r\n");

        if (bodyIndex == -1)
        {
            return false;
        }

        String header = request.substring(0, bodyIndex);
        String body = request.substring(bodyIndex + 4);

    	ByteArrayInputStream in = new ByteArrayInputStream(header.getBytes());
    	BufferedReader reader = new BufferedReader(new InputStreamReader(in));
    	
        int contentLength = 0;
        String headerLine;

        while ((headerLine = reader.readLine()) != null)
        {
            headerLine = headerLine.trim();

            if (headerLine.startsWith("Content-Length:"))
            {
                String contentLengthValue = headerLine.substring(15);

                contentLengthValue = contentLengthValue.trim();

                if (contentLengthValue != null && contentLengthValue.length() > 0)
                {
                    contentLength = Integer.parseInt(contentLengthValue);
                    break;
                }
            }
        }

        if (contentLength == body.length())
        {
            return true;
        }
        else
        {
            return false;
        }
    }
}
Independentsoft - any library, any programming language

JWebServices for Exchange > Tutorial > Push event notification

Need help? Ask our developers:
