org.apache.activemq.artemis.integration.aerogear

Class AeroGearConnectorService

java.lang.Object

org.apache.activemq.artemis.integration.aerogear.AeroGearConnectorService

All Implemented Interfaces:

ActiveMQComponent, ConnectorService, Consumer, org.jboss.aerogear.unifiedpush.message.MessageResponseCallback

public class AeroGearConnectorService
extends Object
implements ConnectorService, Consumer, org.jboss.aerogear.unifiedpush.message.MessageResponseCallback

Constructor Summary

Constructors

Constructor and Description
AeroGearConnectorService(String connectorName, Map<String,Object> configuration, PostOffice postOffice, ScheduledExecutorService scheduledThreadPool)

Method Summary

Modifier and Type	Method and Description
String	debug()
void	disconnect()
List<MessageReference>	getDeliveringMessages()
Filter	getFilter()
String	getName()
HandleStatus	handle(MessageReference reference)
boolean	isStarted()
void	onComplete(int statusCode)
void	onError(Throwable throwable)
void	proceedDeliver(MessageReference reference)
void	start()
void	stop()
String	toManagementString()

Methods inherited from class java.lang.Object

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

Constructor Detail

AeroGearConnectorService

public AeroGearConnectorService(String connectorName,
                                Map<String,Object> configuration,
                                PostOffice postOffice,
                                ScheduledExecutorService scheduledThreadPool)

Method Detail

getName

public String getName()

Specified by:

getName in interface ConnectorService

start

public void start()
           throws Exception

Specified by:

start in interface ActiveMQComponent

Throws:

Exception

stop

public void stop()
          throws Exception

Specified by:

stop in interface ActiveMQComponent

Throws:

Exception

isStarted

public boolean isStarted()

Specified by:

isStarted in interface ActiveMQComponent

handle

public HandleStatus handle(MessageReference reference)
                    throws Exception

Specified by:

handle in interface Consumer

Throws:

Exception

onComplete

public void onComplete(int statusCode)

Specified by:

onComplete in interface org.jboss.aerogear.unifiedpush.message.MessageResponseCallback

onError

public void onError(Throwable throwable)

Specified by:

onError in interface org.jboss.aerogear.unifiedpush.message.MessageResponseCallback

getDeliveringMessages

public List<MessageReference> getDeliveringMessages()

Specified by:

getDeliveringMessages in interface Consumer

proceedDeliver

public void proceedDeliver(MessageReference reference)
                    throws Exception

Specified by:

proceedDeliver in interface Consumer

Throws:

Exception

getFilter

public Filter getFilter()

Specified by:

getFilter in interface Consumer

debug

public String debug()

Specified by:

debug in interface Consumer

toManagementString

public String toManagementString()

Specified by:

toManagementString in interface Consumer

disconnect

public void disconnect()

Specified by:

disconnect in interface Consumer