org.wso2.carbon.databridge.receiver.binary

Class BinaryEventConverter

java.lang.Object

org.wso2.carbon.databridge.receiver.binary.BinaryEventConverter

All Implemented Interfaces:

org.wso2.carbon.databridge.core.EventConverter

public class BinaryEventConverter
extends Object
implements org.wso2.carbon.databridge.core.EventConverter

This class is a implementation EventConverter to create the event from the Binary message. This is used within data bridge to create the event from the row message received.

Method Summary

Modifier and Type	Method and Description
static BinaryEventConverter	getConverter()
org.wso2.carbon.databridge.commons.Event	getEvent(ByteBuffer byteBuffer, org.wso2.carbon.databridge.core.StreamTypeHolder streamTypeHolder)
int	getNumberOfEvents(Object eventBundle)
int	getSize(Object eventBundle)
List<org.wso2.carbon.databridge.commons.Event>	toEventList(Object eventBundle, org.wso2.carbon.databridge.core.StreamTypeHolder streamTypeHolder)
Object[]	toObjectArray(ByteBuffer byteBuffer, org.wso2.carbon.databridge.commons.AttributeType[] attributeTypeOrder, String type)
Map<String,String>	toStringMap(ByteBuffer byteBuffer)

Methods inherited from class java.lang.Object

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

Method Detail

toEventList

public List<org.wso2.carbon.databridge.commons.Event> toEventList(Object eventBundle,
                                                                  org.wso2.carbon.databridge.core.StreamTypeHolder streamTypeHolder)

Specified by:

toEventList in interface org.wso2.carbon.databridge.core.EventConverter

getSize

public int getSize(Object eventBundle)

Specified by:

getSize in interface org.wso2.carbon.databridge.core.EventConverter

getNumberOfEvents

public int getNumberOfEvents(Object eventBundle)

Specified by:

getNumberOfEvents in interface org.wso2.carbon.databridge.core.EventConverter

getEvent

public org.wso2.carbon.databridge.commons.Event getEvent(ByteBuffer byteBuffer,
                                                         org.wso2.carbon.databridge.core.StreamTypeHolder streamTypeHolder)
                                                  throws org.wso2.carbon.databridge.commons.exception.MalformedEventException

Throws:

org.wso2.carbon.databridge.commons.exception.MalformedEventException

toObjectArray

public Object[] toObjectArray(ByteBuffer byteBuffer,
                              org.wso2.carbon.databridge.commons.AttributeType[] attributeTypeOrder,
                              String type)

toStringMap

public Map<String,String> toStringMap(ByteBuffer byteBuffer)

getConverter

public static BinaryEventConverter getConverter()