org.infinispan.remoting.transport.jgroups

Class MarshallerAdapter

java.lang.Object

org.infinispan.remoting.transport.jgroups.MarshallerAdapter

All Implemented Interfaces:

RpcDispatcher.Marshaller

public class MarshallerAdapter
extends Object
implements RpcDispatcher.Marshaller

Bridge between JGroups and Infinispan marshallers

Since:

4.0

Author:

Manik Surtani

Constructor Summary

Constructors

Constructor and Description
MarshallerAdapter(StreamingMarshaller m)

Method Summary

Methods

Modifier and Type	Method and Description
Object	objectFromBuffer(byte[] buf, int offset, int length)
Buffer	objectToBuffer(Object obj) Marshals the object into a byte[] buffer and returns a Buffer with a ref to the underlying byte[] buffer, offset and length. Note that the underlying byte[] buffer must not be changed as this would change the buffer of a message which potentially can get retransmitted, and such a retransmission would then carry a ref to a changed byte[] buffer !

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

MarshallerAdapter

public MarshallerAdapter(StreamingMarshaller m)

Method Detail

objectToBuffer

public Buffer objectToBuffer(Object obj)
                      throws Exception

Description copied from interface: RpcDispatcher.Marshaller

Marshals the object into a byte[] buffer and returns a Buffer with a ref to the underlying byte[] buffer, offset and length.
Note that the underlying byte[] buffer must not be changed as this would change the buffer of a message which potentially can get retransmitted, and such a retransmission would then carry a ref to a changed byte[] buffer !

Specified by:

objectToBuffer in interface RpcDispatcher.Marshaller

Returns:

Throws:

Exception

objectFromBuffer

public Object objectFromBuffer(byte[] buf,
                      int offset,
                      int length)
                        throws Exception

Specified by:

objectFromBuffer in interface RpcDispatcher.Marshaller

Throws:

Exception