Provides a channel / queue wrapper as well as an nEventPublisher implementation that automatically fragments published events larger than a specified byte size into smaller event fragments. More...
Public Member Functions | |
nConsumeEventFragmentWriter (nAbstractChannel store, int maxSize) | |
Construct a writer where the events are written directly to the nAbstractChannel supplied. More... | |
nConsumeEventFragmentWriter (nEventPublisher pub, int maxSize) | |
Constructs a write where events are written to the next nEventPublisher. More... | |
void | publish (nConsumeEvent evt) |
Publishes an nConsumeEvent to the nEventPublisher or nAbstractChannel after it maybe fragemented. More... | |
Provides a channel / queue wrapper as well as an nEventPublisher implementation that automatically fragments published events larger than a specified byte size into smaller event fragments.
com.pcbsys.nirvana.client.nConsumeEventFragmentWriter.nConsumeEventFragmentWriter | ( | nAbstractChannel | store, |
int | maxSize | ||
) |
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 | ||
) |
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 | ) |
Publishes an nConsumeEvent to the nEventPublisher or nAbstractChannel after it maybe fragemented.
evt | the event to fragment |