org.apache.asterix.metadata.feeds

Class XAQLFeedMessage

java.lang.Object

org.apache.asterix.common.feeds.message.FeedMessage

org.apache.asterix.metadata.feeds.XAQLFeedMessage

All Implemented Interfaces:

Serializable, IFeedMessage, org.apache.hyracks.api.dataflow.value.JSONSerializable

public class XAQLFeedMessage
extends FeedMessage

A feed control message indicating the need to execute a give AQL.

See Also:

Serialized Form

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.asterix.common.feeds.api.IFeedMessage

IFeedMessage.MessageType

Field Summary

Fields inherited from class org.apache.asterix.common.feeds.message.FeedMessage

messageType

Constructor Summary

Constructors

Constructor and Description
XAQLFeedMessage(FeedConnectionId connectionId, String aql)

Method Summary

Methods

Modifier and Type	Method and Description
String	getAql()
FeedConnectionId	getConnectionId()
org.json.JSONObject	toJSON()
String	toString()

Methods inherited from class org.apache.asterix.common.feeds.message.FeedMessage

getMessageType

Methods inherited from class java.lang.Object

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

Constructor Detail

XAQLFeedMessage

public XAQLFeedMessage(FeedConnectionId connectionId,
               String aql)

Method Detail

toString

public String toString()

Overrides:

toString in class Object

getConnectionId

public FeedConnectionId getConnectionId()

getAql

public String getAql()

toJSON

public org.json.JSONObject toJSON()
                           throws org.json.JSONException

Throws:

org.json.JSONException