org.wso2.carbon.databridge.commons

Class StreamDefinition

java.lang.Object

org.wso2.carbon.databridge.commons.StreamDefinition

public class StreamDefinition
extends Object

WSO2 Event Stream Definition

Constructor Summary

Constructors

Constructor and Description
StreamDefinition(String name)
StreamDefinition(String name, String version)
StreamDefinition(String name, String version, String streamId) Deprecated.

Method Summary

Modifier and Type	Method and Description
void	addCorrelationData(String name, AttributeType type)
void	addMetaData(String name, AttributeType type)
void	addPayloadData(String name, AttributeType type)
void	addTag(String tag)
boolean	equals(Object o) Stream Id is not used for comparing definitions This is because this method is used to identify duplicates
List<Attribute>	getAttributeListForKey(String key)
List<Attribute>	getCorrelationData()
String	getDescription()
List<Attribute>	getMetaData()
String	getName()
String	getNickName()
List<Attribute>	getPayloadData()
String	getStreamId()
List<String>	getTags()
String	getVersion()
int	hashCode() Stream Id is not used for comparing definitions This is because this method is used to identify duplicates
void	setCorrelationData(List<Attribute> correlationData)
void	setDescription(String description)
void	setMetaData(List<Attribute> metaData)
void	setNickName(String nickName)
void	setPayloadData(List<Attribute> payloadData)
void	setTags(List<String> tags)
String	toString()

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Constructor Detail

StreamDefinition

@Deprecated
public StreamDefinition(String name,
                                    String version,
                                    String streamId)
                             throws MalformedStreamDefinitionException

Deprecated.

Throws:

MalformedStreamDefinitionException

StreamDefinition

public StreamDefinition(String name,
                        String version)
                 throws MalformedStreamDefinitionException

Throws:

MalformedStreamDefinitionException

StreamDefinition

public StreamDefinition(String name)

Method Detail

setNickName

public void setNickName(String nickName)

setDescription

public void setDescription(String description)

setTags

public void setTags(List<String> tags)

setMetaData

public void setMetaData(List<Attribute> metaData)

setCorrelationData

public void setCorrelationData(List<Attribute> correlationData)

setPayloadData

public void setPayloadData(List<Attribute> payloadData)

getStreamId

public String getStreamId()

getName

public String getName()

getVersion

public String getVersion()

getNickName

public String getNickName()

getDescription

public String getDescription()

getTags

public List<String> getTags()

getMetaData

public List<Attribute> getMetaData()

getCorrelationData

public List<Attribute> getCorrelationData()

getPayloadData

public List<Attribute> getPayloadData()

getAttributeListForKey

public List<Attribute> getAttributeListForKey(String key)

equals

public boolean equals(Object o)

Stream Id is not used for comparing definitions This is because this method is used to identify duplicates

Overrides:

equals in class Object

Parameters:

o - compared Object

Returns:

true if equal else false

hashCode

public int hashCode()

Stream Id is not used for comparing definitions This is because this method is used to identify duplicates

Overrides:

hashCode in class Object

Returns:

hash code

addTag

public void addTag(String tag)

addMetaData

public void addMetaData(String name,
                        AttributeType type)

addCorrelationData

public void addCorrelationData(String name,
                               AttributeType type)

addPayloadData

public void addPayloadData(String name,
                           AttributeType type)

toString

public String toString()

Overrides:

toString in class Object