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, java.lang.String uri, java.lang.String proxyUrlBase)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description voidclose()java.lang.StringfriendlyName()voidinit()voidonAdaptrisMessage(AdaptrisMessage msg, java.util.function.Consumer<AdaptrisMessage> onSuccess, java.util.function.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 Detail
-
ProxyWorker
public ProxyWorker(EmbeddedConnection conn, java.lang.String uri, java.lang.String proxyUrlBase)
-
-
Method Detail
-
init
public void init() throws CoreException- Specified by:
initin interfaceComponentLifecycle- Overrides:
initin classStandaloneConsumer- Throws:
CoreException
-
close
public void close()
- Specified by:
closein interfaceComponentLifecycle- Overrides:
closein classStandaloneConsumer
-
onAdaptrisMessage
public void onAdaptrisMessage(AdaptrisMessage msg, java.util.function.Consumer<AdaptrisMessage> onSuccess, java.util.function.Consumer<AdaptrisMessage> onFailure)
- Specified by:
onAdaptrisMessagein interfaceAdaptrisMessageListener
-
friendlyName
public java.lang.String friendlyName()
- Specified by:
friendlyNamein interfaceAdaptrisMessageListener
-
-