Package park :: Package core :: Module xmlrpc_service :: Class JobServices

Class JobServices

Instance Methods

put(self, job)
Add a job to the queue, returning the job id.

source code

listenfor(self, key, messagetype)
Put messages for key on queue.

source code

next_message(self, timeout=0)
Return the next queued message for the job.

source code

send_message(self, key, message)
Post a message to the message queue.

source code

log_error(self, coded_object)
Receive a log message from somewhere in the world.

source code

set_header(self, key, message)
Set the queue header for key.

source code

get_header(self, key)
Get the queue header for key.

source code

Class Variables
	codec = `codec`

Method Details

Put messages for key on queue. The key is usually jobid.

Return the next queued message for the job.

If timeout is zero this routine waits until a message is available.

Post a message to the message queue. All clients listening on message.jobid will receive this message.

Receive a log message from somewhere in the world.

This message will be forwarded to whomever is listening for these types of messages, as well as logged on the named queue.

Get the queue header for key. Returns none if there is no queue for key.