- com
- pcbsys
- nirvana
- client
- nConsumeEventFragmentWriter
This class will break up events when the data portion of the event is greater then the threshold specified. More...
Public Member Functions | |
nConsumeEventFragmentWriter (nAbstractChannel store, int maxSize) throws nIllegalArgumentException | |
Construct a writer where the events are written directly to the nAbstractChannel supplied. More... | |
nConsumeEventFragmentWriter (nEventPublisher pub, int maxSize) throws nIllegalArgumentException | |
Constructs a write where events are written to the next nEventPublisher. More... | |
void | publish (nConsumeEvent evt) throws nTransactionException, nSessionPausedException, nSessionNotConnectedException, nSecurityException, nRequestTimedOutException, nUnexpectedResponseException, nChannelNotFoundException, nIllegalArgumentException, nMaxBufferSizeExceededException |
Publishes an nConsumeEvent to the nEventPublisher or nAbstractChannel after it maybe fragemented. More... | |
This class will break up events when the data portion of the event is greater then the threshold specified.
When events are published via this class, if the data is greater then the maxSize specified in the constructors, then the event is split across multiple events where each events data is equal or less then the maxSize specified.
com.pcbsys.nirvana.client.nConsumeEventFragmentWriter.nConsumeEventFragmentWriter | ( | nAbstractChannel | store, |
int | maxSize | ||
) | throws nIllegalArgumentException |
Construct a writer where the events are written directly to the nAbstractChannel supplied.
store | the channel / queue onto which the fragmented events will be written |
maxSize | the maximum size of each fragmented event in bytes |
nIllegalArgumentException | if maxSize < 0 or store is null |
com.pcbsys.nirvana.client.nConsumeEventFragmentWriter.nConsumeEventFragmentWriter | ( | nEventPublisher | pub, |
int | maxSize | ||
) | throws nIllegalArgumentException |
Constructs a write where events are written to the next nEventPublisher.
pub | - the event publisher to use in this fragment writer |
maxSize | the maximum size of each event fragment. |
nIllegalArgumentException | if maxSize < 0 or pub is null |
void com.pcbsys.nirvana.client.nConsumeEventFragmentWriter.publish | ( | nConsumeEvent | evt | ) | throws nTransactionException, nSessionPausedException, nSessionNotConnectedException, nSecurityException, nRequestTimedOutException, nUnexpectedResponseException, nChannelNotFoundException, nIllegalArgumentException, nMaxBufferSizeExceededException |
Publishes an nConsumeEvent to the nEventPublisher or nAbstractChannel after it maybe fragemented.
evt | the event to fragment |
Implements com.pcbsys.nirvana.client.nEventPublisher.