- com
- pcbsys
- nirvana
- client
- nConsumeEventCompressWriter
This is a helper class and enables clients to compress events simply prior to them being published to the actual store. More...
Public Member Functions | |
| nConsumeEventCompressWriter (nAbstractChannel store) throws nIllegalArgumentException | |
| Constructs a new nConsumeEventCompressWriter using the nAbstractChannel supplied. More... | |
| nConsumeEventCompressWriter (nEventPublisher publisher) throws nIllegalArgumentException | |
| Constructs a new nConsumeEventCompressWriter using the nEventPublisher supplied. More... | |
| void | publish (nConsumeEvent evt) throws nTransactionException, nSessionPausedException, nSessionNotConnectedException, nSecurityException, nRequestTimedOutException, nUnexpectedResponseException, nChannelNotFoundException, nIllegalArgumentException, nMaxBufferSizeExceededException |
| Publishs the event evt but will compress the events data prior to publishing it to the server. More... | |
This is a helper class and enables clients to compress events simply prior to them being published to the actual store.
To uncompress the events use the nConsumeEventCompressReader.
| com.pcbsys.nirvana.client.nConsumeEventCompressWriter.nConsumeEventCompressWriter | ( | nAbstractChannel | store | ) | throws nIllegalArgumentException |
Constructs a new nConsumeEventCompressWriter using the nAbstractChannel supplied.
Will compress any event sent via the publish call to the nAbstractChannel, this could be a queue or a channel.
| store | the channel / queue on which the writer will be used |
| nIllegalArgumentException | if the channel / queue is null |
| com.pcbsys.nirvana.client.nConsumeEventCompressWriter.nConsumeEventCompressWriter | ( | nEventPublisher | publisher | ) | throws nIllegalArgumentException |
Constructs a new nConsumeEventCompressWriter using the nEventPublisher supplied.
Will compress any event sent via the publish call to the nEventPublisher, this allows the nEventPublisher to be stacked, so that one nEventPublisher can call another before the event is sent to the nAbstractChannel
| publisher | the event publisher used by this compress writer |
| nIllegalArgumentException | if the publisher is null |
| void com.pcbsys.nirvana.client.nConsumeEventCompressWriter.publish | ( | nConsumeEvent | evt | ) | throws nTransactionException, nSessionPausedException, nSessionNotConnectedException, nSecurityException, nRequestTimedOutException, nUnexpectedResponseException, nChannelNotFoundException, nIllegalArgumentException, nMaxBufferSizeExceededException |
Publishs the event evt but will compress the events data prior to publishing it to the server.
If the resultant compressed byte[] is larger then the original then no compression will be done.
| evt | the event to compress and publish |
Implements com.pcbsys.nirvana.client.nEventPublisher.