public abstract class AbstractSimpleTransport extends AbstractTransport
Transport
interface; handles batches and translate to individual method
invocations.
Handles batches of messages and ignoring null payload messages (by
default). Implementors will typically sub-class this class,
providing an implementation of the deliver methods.chainId, config, hostSide
Constructor and Description |
---|
AbstractSimpleTransport(java.util.Map<java.lang.String,java.lang.Object> config,
java.lang.String chainId,
org.apache.log4j.Logger logger)
Constructor, passing parameters to AbstractTransport.
|
Modifier and Type | Method and Description |
---|---|
abstract void |
deliverMessageTowardsTransport(Message message)
Deliver an individual non-null message.
|
void |
deliverNullPayloadTowardsTransport(Message message)
Deliver an individual null-payload message.
|
void |
handleException(java.lang.Exception ex,
Message message,
boolean towardsTransport)
Handle exception thrown from delivering messages.
|
void |
sendBatchTowardsTransport(java.util.List<Message> messages)
Deliver a batch of messages and pass them on to the next
plug-in synchronously.
|
hostReady, setNextTowardsHost, shutdown, start
public AbstractSimpleTransport(java.util.Map<java.lang.String,java.lang.Object> config, java.lang.String chainId, org.apache.log4j.Logger logger)
public void sendBatchTowardsTransport(java.util.List<Message> messages)
If the transport can deliver multiple events in a batch more efficiently, then it should override this method.
public abstract void deliverMessageTowardsTransport(Message message) throws java.lang.Exception
java.lang.Exception
public void deliverNullPayloadTowardsTransport(Message message) throws java.lang.Exception
java.lang.Exception
public void handleException(java.lang.Exception ex, Message message, boolean towardsTransport)
Submit a bug or feature
Copyright (c) 2013-2016 Software AG, Darmstadt, Germany and/or Software AG USA Inc., Reston, VA, USA, and/or its subsidiaries and/or its affiliates and/or their licensors. Use, reproduction, transfer, publication or disclosure is prohibited except as specifically provided for in your License Agreement with Software AG.