org.ametiste.scm.messaging.sender

Class HttpEventSender

java.lang.Object

org.ametiste.scm.messaging.sender.HttpEventSender

All Implemented Interfaces:

EventSender

public class HttpEventSender
extends java.lang.Object
implements EventSender

HttpEventSender is a default implementation of {EventSender} interface that send messages via HTTP protocol.

Sender sent messages as array of objects. If we send one event, sender automatically wrap it.

Constructor Summary

Constructors

Constructor and Description
HttpEventSender(org.apache.http.client.HttpClient client) Create HttpEventSender with specified HttpClient instance and default event class to EventDTOFactory map.
HttpEventSender(org.apache.http.client.HttpClient client, java.util.Map<java.lang.Class,org.ametiste.scm.messaging.transport.http.dto.factory.EventDTOFactory> eventConverterMap) Create HttpEventSender with specified HttpClient instance and event class to EventDTOFactory map.

Method Summary

Modifier and Type	Method and Description
static org.apache.http.impl.client.CloseableHttpClient	createHttpClient(int connectionTimeout, int readTimeout) Create CloseableHttpClient with custom request configuration (timeouts).
void	send(java.net.URI receiver, java.util.Collection<org.ametiste.scm.messaging.data.transport.TransportMessage<org.ametiste.scm.messaging.data.event.Event>> messages) Send TransportMessage<Event> bulk to receiver.
void	send(java.net.URI receiver, org.ametiste.scm.messaging.data.transport.TransportMessage<org.ametiste.scm.messaging.data.event.Event> message) Send TransportMessage<Event> to receiver.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

HttpEventSender

public HttpEventSender(org.apache.http.client.HttpClient client)

Create HttpEventSender with specified HttpClient instance and default event class to EventDTOFactory map.

Parameters:

client - Apache HttpClient instance.

HttpEventSender

public HttpEventSender(org.apache.http.client.HttpClient client,
                       java.util.Map<java.lang.Class,org.ametiste.scm.messaging.transport.http.dto.factory.EventDTOFactory> eventConverterMap)

Create HttpEventSender with specified HttpClient instance and event class to EventDTOFactory map.

For creating HttpClient you can use static method createHttpClient.

Parameters:

client - Apache HttpClient instance.

eventConverterMap - event class to EventDTOFactory map.

Method Detail

send

public void send(java.net.URI receiver,
                 org.ametiste.scm.messaging.data.transport.TransportMessage<org.ametiste.scm.messaging.data.event.Event> message)
          throws EventSendException

Description copied from interface: EventSender

Send TransportMessage<Event> to receiver.

Specified by:

send in interface EventSender

Parameters:

receiver - URI to event receiver endpoint.

message - message to send.

Throws:

EventSendException - when any error occurred during transmit process.

send

public void send(java.net.URI receiver,
                 java.util.Collection<org.ametiste.scm.messaging.data.transport.TransportMessage<org.ametiste.scm.messaging.data.event.Event>> messages)
          throws EventSendException

Description copied from interface: EventSender

Send TransportMessage<Event> bulk to receiver.

Specified by:

send in interface EventSender

Parameters:

receiver - URI to event receiver endpoint.

messages - list with messages to send.

Throws:

EventSendException - when any error occurred during transmit process.

createHttpClient

public static org.apache.http.impl.client.CloseableHttpClient createHttpClient(int connectionTimeout,
                                                                               int readTimeout)

Create CloseableHttpClient with custom request configuration (timeouts).

Parameters:

connectionTimeout - connection timeout in milliseconds.

readTimeout - read timeout in milliseconds.