public class GraphiteRabbitMQ extends Object implements GraphiteSender
Constructor and Description |
---|
GraphiteRabbitMQ(com.rabbitmq.client.ConnectionFactory connectionFactory,
String exchange)
Creates a new client with a given a
ConnectionFactory and an amqp exchange |
GraphiteRabbitMQ(String rabbitHost,
Integer rabbitPort,
String rabbitUsername,
String rabbitPassword,
String exchange)
Creates a new client given connection details
|
GraphiteRabbitMQ(String rabbitHost,
Integer rabbitPort,
String rabbitUsername,
String rabbitPassword,
String exchange,
Integer rabbitConnectionTimeoutMS,
Integer rabbitSocketTimeoutMS,
Integer rabbitRequestedHeartbeatInSeconds)
Creates a new client given connection details
|
Modifier and Type | Method and Description |
---|---|
void |
close() |
void |
connect()
Connects to the server.
|
void |
flush()
Flushes buffer, if applicable
|
int |
getFailures()
Returns the number of failed writes to the server.
|
boolean |
isConnected()
Returns true if ready to send data
|
String |
sanitize(String s) |
void |
send(String name,
String value,
long timestamp)
Sends the given measurement to the server.
|
public GraphiteRabbitMQ(com.rabbitmq.client.ConnectionFactory connectionFactory, String exchange)
ConnectionFactory
and an amqp exchangeconnectionFactory
- the ConnectionFactory
used to establish connection and publish to graphite serverexchange
- the amqp exchangepublic GraphiteRabbitMQ(String rabbitHost, Integer rabbitPort, String rabbitUsername, String rabbitPassword, String exchange)
rabbitHost
- the rabbitmq server hostrabbitPort
- the rabbitmq server portrabbitUsername
- the rabbitmq server usernamerabbitPassword
- the rabbitmq server passwordexchange
- the amqp exchangepublic GraphiteRabbitMQ(String rabbitHost, Integer rabbitPort, String rabbitUsername, String rabbitPassword, String exchange, Integer rabbitConnectionTimeoutMS, Integer rabbitSocketTimeoutMS, Integer rabbitRequestedHeartbeatInSeconds)
rabbitHost
- the rabbitmq server hostrabbitPort
- the rabbitmq server portrabbitUsername
- the rabbitmq server usernamerabbitPassword
- the rabbitmq server passwordexchange
- the amqp exchangerabbitConnectionTimeoutMS
- the connection timeout in millisecondsrabbitSocketTimeoutMS
- the socket timeout in millisecondsrabbitRequestedHeartbeatInSeconds
- the hearthbeat in secondspublic void connect() throws IllegalStateException, IOException
GraphiteSender
connect
in interface GraphiteSender
IllegalStateException
- if the client is already connectedIOException
- if there is an error connectingpublic boolean isConnected()
GraphiteSender
isConnected
in interface GraphiteSender
public void send(String name, String value, long timestamp) throws IOException
GraphiteSender
send
in interface GraphiteSender
name
- the name of the metricvalue
- the value of the metrictimestamp
- the timestamp of the metricIOException
- if there was an error sending the metricpublic void flush() throws IOException
GraphiteSender
flush
in interface GraphiteSender
IOException
public void close() throws IOException
close
in interface Closeable
close
in interface AutoCloseable
IOException
public int getFailures()
GraphiteSender
getFailures
in interface GraphiteSender
Copyright © 2014. All Rights Reserved.