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

static BinaryEventConverter	getConverter()
org.wso2.carbon.databridge.commons.Event	getEvent(String eventMessage, org.wso2.carbon.databridge.core.StreamTypeHolder streamTypeHolder)
List<org.wso2.carbon.databridge.commons.Event>	toEventList(Object eventBundle, org.wso2.carbon.databridge.core.StreamTypeHolder streamTypeHolder)
Object[]	toObjectArray(String attributeMessage, org.wso2.carbon.databridge.commons.AttributeType[] attributeTypeOrder, String type)
Map<String,String>	toStringMap(String attributeMessage)

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

getEvent

public org.wso2.carbon.databridge.commons.Event getEvent(String eventMessage,
                                                         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(String attributeMessage,
                              org.wso2.carbon.databridge.commons.AttributeType[] attributeTypeOrder,
                              String type)

toStringMap

public Map<String,String> toStringMap(String attributeMessage)

getConverter

public static BinaryEventConverter getConverter()