u.r.RabbitMQPublisher(AMQClient) : class documentation

Part of udplog.rabbitmq View Source View In Hierarchy

Protocol for passing UDP Log events to Logstash via RabbitMQ.

To handle push-back from the RabbitMQ server, log events are sent from a local in-memory queue. If queueSize is set and the queue is full, old items are dropped in favor of the new ones.

Line #	Kind	Name	Docs
0	Instance Variable	queueSize	Optional maximum queue size.
43	Method	__init__	Undocumented
62	Method	connectionMade	Add this protocol as a consumer of log events.
77	Method	gotConnection	Undocumented
95	Method	connectionLost	Remove this protocol as a consumer of log events.
105	Method	sendEvent	Write an event to Logstash.

queueSize =

Optional maximum queue size.

def __init__(self, dispatcher, username='guest', password='guest', vhost='/', exchange='logs', queueSize=None): (source)

Undocumented

def connectionMade(self): (source)

Add this protocol as a consumer of log events.

@defer.inlineCallbacks
def gotConnection(self): (source)

Undocumented

def connectionLost(self, reason): (source)

Remove this protocol as a consumer of log events.

def sendEvent(self, event): (source)

Write an event to Logstash.

API Documentation for udplog, generated by pydoctor at 2014-02-17 15:26:29.