Package interlok.management.proxy

Class ProxyWorker

java.lang.Object

com.adaptris.core.StandaloneConsumer

interlok.management.proxy.ProxyWorker

All Implemented Interfaces:

AdaptrisComponent, AdaptrisMessageConsumer, AdaptrisMessageListener, AdaptrisMessageWorker, ComponentLifecycle, ComponentLifecycleExtension, MessageEventGenerator, StateManagedComponent

public class ProxyWorker
extends StandaloneConsumer
implements AdaptrisMessageListener

Constructor Summary

Constructors

Constructor	Description
ProxyWorker(EmbeddedConnection conn, String uri, String proxyUrlBase)

Method Summary

Modifier and Type	Method	Description
void	close()
String	friendlyName()
void	init()
void	onAdaptrisMessage(AdaptrisMessage msg, Consumer<AdaptrisMessage> onSuccess, Consumer<AdaptrisMessage> onFailure)

Methods inherited from class com.adaptris.core.StandaloneConsumer

changeState, createName, createQualifier, decode, encode, getConnection, getConsumer, getEncoder, getIsTrackingEndpoint, getMessageFactory, getUniqueId, handleConnectionException, isTrackingEndpoint, prepare, registerAdaptrisMessageListener, registerConnection, requestClose, requestInit, requestStart, requestStop, retrieveComponentState, retrieveConnection, setConnection, setConsumer, setEncoder, setIsTrackingEndpoint, setMessageFactory, start, stop

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.adaptris.core.AdaptrisMessageConsumer

consumeLocationKey

Methods inherited from interface com.adaptris.core.AdaptrisMessageListener

onAdaptrisMessage, onAdaptrisMessage

Constructor Details

ProxyWorker

public ProxyWorker(EmbeddedConnection conn,
 String uri,
 String proxyUrlBase)

Method Details

init

public void init()
          throws CoreException

Specified by:

init in interface ComponentLifecycle

Overrides:

init in class StandaloneConsumer

Throws:

CoreException

close

public void close()

Specified by:

close in interface ComponentLifecycle

Overrides:

close in class StandaloneConsumer

onAdaptrisMessage

public void onAdaptrisMessage(AdaptrisMessage msg,
 Consumer<AdaptrisMessage> onSuccess,
 Consumer<AdaptrisMessage> onFailure)

Specified by:

onAdaptrisMessage in interface AdaptrisMessageListener

friendlyName

public String friendlyName()

Specified by:

friendlyName in interface AdaptrisMessageListener