Package jenkins.plugins.logstash.persistence

Class RabbitMqDao

java.lang.Object

jenkins.plugins.logstash.persistence.AbstractLogstashIndexerDao

jenkins.plugins.logstash.persistence.HostBasedLogstashIndexerDao

jenkins.plugins.logstash.persistence.RabbitMqDao

All Implemented Interfaces:

Serializable, LogstashIndexerDao

public class RabbitMqDao
extends HostBasedLogstashIndexerDao

RabbitMQ Data Access Object. TODO: support TLS TODO: support vhost

Since:

1.0.0

Author:

Rusty Gerard

See Also:

• Serialized Form

Nested Class Summary

Nested classes/interfaces inherited from interface jenkins.plugins.logstash.persistence.LogstashIndexerDao

LogstashIndexerDao.IndexerType, LogstashIndexerDao.SyslogFormat, LogstashIndexerDao.SyslogProtocol

Constructor Summary

Constructors

Constructor	Description
RabbitMqDao(String host, int port, String key, String username, String password, Charset charset, String virtualHost)

Method Summary

Modifier and Type	Method	Description
String	getPassword()
String	getQueue()
String	getUsername()
String	getVirtualHost()
void	push(String data)	Sends the log data to the Logstash indexer.

Methods inherited from class jenkins.plugins.logstash.persistence.HostBasedLogstashIndexerDao

getDescription, getHost, getPort

Methods inherited from class jenkins.plugins.logstash.persistence.AbstractLogstashIndexerDao

buildPayload

Methods inherited from class java.lang.Object

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

Constructor Details

RabbitMqDao

public RabbitMqDao(String host,
 int port,
 String key,
 String username,
 String password,
 Charset charset,
 String virtualHost)

Method Details

getQueue

public String getQueue()

getUsername

public String getUsername()

getPassword

public String getPassword()

getVirtualHost

public String getVirtualHost()

push

public void push(String data)
          throws IOException

Description copied from interface: LogstashIndexerDao

Sends the log data to the Logstash indexer.

Parameters:

data - The serialized data, not null

Throws:

IOException - The data is not written to the server