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 |