1 #ifndef _QmfEngineAgent_
2 #define _QmfEngineAgent_
75 Agent(
char* label,
bool internalStore=
true);
void newSession()
A new AMQP session has been established for Agent communication.
void queryResponse(uint32_t sequence, Object &object, bool prop=true, bool stat=true)
Send a content indication to the QMF bus.
void popXmt()
Remove and discard one message from the head of the transmit queue.
void methodResponse(uint32_t sequence, uint32_t status, char *text, const Value &arguments)
Respond to a method request.
const ObjectId * allocObjectId(uint64_t persistId)
Allocate an object-id for an object that will be managed by the application.
void setStoreDir(const char *path)
Configure the directory path for storing persistent data.
const ObjectId * addObject(Object &obj, uint64_t persistId)
Give an object to the Agent for storage and management.
void setTransferDir(const char *path)
Configure the directory path for files transferred over QMF.
Agent(char *label, bool internalStore=true)
void handleRcvMessage(Message &message)
Pass messages received from the AMQP session to the Agent engine.
void popEvent()
Remove and discard one event from the head of the event queue.
void registerClass(SchemaObjectClass *cls)
Register a schema class with the Agent.
void startProtocol()
Start the QMF Agent protocol.
bool getEvent(AgentEvent &event) const
Get the next application event from the agent engine.
void heartbeat()
This method is called periodically so the agent can supply a heartbeat.
void raiseEvent(Event &event)
Raise an event into the QMF network.
void queryComplete(uint32_t sequence)
Indicate the completion of a query.
const SchemaObjectClass * objectClass
bool getXmtMessage(Message &item) const
Get the next message to be sent to the AMQP network.
Agent - Protocol engine for the QMF agent.