org.turro.push.service.PushService Class Reference

Inheritance diagram for org.turro.push.service.PushService:

Collaboration diagram for org.turro.push.service.PushService:

Public Member Functions
	PushService ()
	PushService (String gcmApiKey)
	PushService (KeyPair keyPair)
	PushService (KeyPair keyPair, String subject)
	PushService (String publicKey, String privateKey) throws GeneralSecurityException
	PushService (String publicKey, String privateKey, String subject) throws GeneralSecurityException
HttpResponse	send (Notification notification) throws GeneralSecurityException, IOException, JoseException, ExecutionException, InterruptedException
HttpResponse	send (Notification notification, Encoding encoding) throws GeneralSecurityException, IOException, JoseException
HttpPost	preparePost (Notification notification, Encoding encoding) throws GeneralSecurityException, IOException, JoseException
void	sendAsync (Notification notification, Consumer< SimpleHttpResponse > completed, Consumer< Exception > failed, Runnable cancelled) throws GeneralSecurityException, IOException, JoseException, ExecutionException, InterruptedException
void	sendAsync (Notification notification, Encoding encoding, Consumer< SimpleHttpResponse > completed, Consumer< Exception > failed, Runnable cancelled) throws GeneralSecurityException, IOException, JoseException
SimpleHttpRequest	prepareAsyncPost (Notification notification, Encoding encoding) throws GeneralSecurityException, IOException, JoseException

Detailed Description

Author

Lluis Turró Cutiller lluis.nosp@m.@tur.nosp@m.ro.or.nosp@m.g

Definition at line 45 of file PushService.java.

Constructor & Destructor Documentation

PushService() [1/6]

org.turro.push.service.PushService.PushService

(

)

Definition at line 47 of file PushService.java.

                       {
  }

PushService() [2/6]

org.turro.push.service.PushService.PushService

(

String

gcmApiKey

)

Definition at line 50 of file PushService.java.

                                       {
    super(gcmApiKey);
  }

PushService() [3/6]

org.turro.push.service.PushService.PushService

(

KeyPair

keyPair

)

Definition at line 54 of file PushService.java.

                                      {
    super(keyPair);
  }

PushService() [4/6]

org.turro.push.service.PushService.PushService	(	KeyPair	keyPair,
		String	subject
	)

Definition at line 58 of file PushService.java.

                                                      {
    super(keyPair, subject);
  }

PushService() [5/6]

org.turro.push.service.PushService.PushService	(	String	publicKey,
		String	privateKey
	)		throws GeneralSecurityException

Definition at line 62 of file PushService.java.

                                                                                          {
    super(publicKey, privateKey);
  }

PushService() [6/6]

org.turro.push.service.PushService.PushService	(	String	publicKey,
		String	privateKey,
		String	subject
	)		throws GeneralSecurityException

Definition at line 66 of file PushService.java.

                                                                                                          {
    super(publicKey, privateKey, subject);
  }

Member Function Documentation

prepareAsyncPost()

SimpleHttpRequest org.turro.push.service.PushService.prepareAsyncPost	(	Notification	notification,
		Encoding	encoding
	)		throws GeneralSecurityException, IOException, JoseException

Definition at line 122 of file PushService.java.

                                                                                                                                                      {
    HttpRequest request = prepareRequest(notification, encoding);
    SimpleHttpRequest httpPost = SimpleRequestBuilder.create(Method.POST).setUri(request.getUrl()).build();
    request.getHeaders().forEach(httpPost::addHeader);
    httpPost.setBody(request.getBody(), ContentType.APPLICATION_OCTET_STREAM);
    return httpPost;
  }

Here is the call graph for this function:

Here is the caller graph for this function:

preparePost()

HttpPost org.turro.push.service.PushService.preparePost	(	Notification	notification,
		Encoding	encoding
	)		throws GeneralSecurityException, IOException, JoseException

Definition at line 81 of file PushService.java.

                                                                                                                                        {
    HttpRequest request = prepareRequest(notification, encoding);
    HttpPost httpPost = new HttpPost(request.getUrl());
    request.getHeaders().forEach(httpPost::addHeader);
    if (request.getBody() != null) {
      httpPost.setEntity(new ByteArrayEntity(request.getBody(), ContentType.APPLICATION_OCTET_STREAM));
    }
    return httpPost;
  }

Here is the call graph for this function:

Here is the caller graph for this function:

send() [1/2]

HttpResponse org.turro.push.service.PushService.send

(

Notification

notification

)

throws GeneralSecurityException, IOException, JoseException, ExecutionException, InterruptedException

Definition at line 70 of file PushService.java.

                                                                                                                                                            {
    return send(notification, Encoding.AESGCM);
  }

Here is the caller graph for this function:

send() [2/2]

HttpResponse org.turro.push.service.PushService.send	(	Notification	notification,
		Encoding	encoding
	)		throws GeneralSecurityException, IOException, JoseException

Definition at line 74 of file PushService.java.

                                                                                                                                     {
    HttpPost httpPost = preparePost(notification, encoding);
    try(CloseableHttpClient client = HttpClientBuilder.create().build()) {
      return client.execute(httpPost);
    }
  }

Here is the call graph for this function:

sendAsync() [1/2]

void org.turro.push.service.PushService.sendAsync	(	Notification	notification,
		Consumer< SimpleHttpResponse >	completed,
		Consumer< Exception >	failed,
		Runnable	cancelled
	)		throws GeneralSecurityException, IOException, JoseException, ExecutionException, InterruptedException

Definition at line 91 of file PushService.java.

                                                                                                                                                                {
    sendAsync(notification, Encoding.AESGCM, completed, failed, cancelled);
  }

sendAsync() [2/2]

void org.turro.push.service.PushService.sendAsync	(	Notification	notification,
		Encoding	encoding,
		Consumer< SimpleHttpResponse >	completed,
		Consumer< Exception >	failed,
		Runnable	cancelled
	)		throws GeneralSecurityException, IOException, JoseException

Definition at line 96 of file PushService.java.

                                                                                                                      {
    SimpleHttpRequest httpPost = prepareAsyncPost(notification, encoding);
    final CloseableHttpAsyncClient httpClient = HttpAsyncClientBuilder.create().build();
    httpClient.start();
    httpClient.execute(httpPost, new FutureCallback<SimpleHttpResponse>() {
      @Override
      public void completed(SimpleHttpResponse result) {
        if(completed != null) completed.accept(result);
        httpClient.close(CloseMode.GRACEFUL);
      }
 
      @Override
      public void failed(Exception ex) {
        if(failed != null) failed.accept(ex);
        httpClient.close(CloseMode.GRACEFUL);
      }
 
      @Override
      public void cancelled() {
        if(cancelled != null) cancelled.run();
        httpClient.close(CloseMode.GRACEFUL);
      }
    });
  }

Here is the call graph for this function:

---

The documentation for this class was generated from the following file:

• PushService.java