"Fossies" - the Fresh Open Source Software Archive  

Source code changes of the file "moskito-extensions/moskito-php/src/main/java/net/anotheria/extensions/php/connectors/impl/RabbitMQConnector.java" between
moskito-moskito-2.9.3.tar.gz and moskito-moskito-2.10.0.tar.gz

About: MoSKito (Monitoring System Kit) is a framework for java application monitoring. Sources.

RabbitMQConnector.java  (moskito-moskito-2.9.3)	:	RabbitMQConnector.java  (moskito-moskito-2.10.0)
skipping to change at line 76		skipping to change at line 76
*/		*/
@Override		@Override
public void initWithDefaultProperties(Properties properties) throws Connecto rInitException {		public void initWithDefaultProperties(Properties properties) throws Connecto rInitException {
log.debug("Starting to initWithDefaultProperties RabbitMQ connector in p hp plugin...");		log.debug("Starting to initWithDefaultProperties RabbitMQ connector in p hp plugin...");
ConnectionFactory factory = new ConnectionFactory();		ConnectionFactory factory = new ConnectionFactory();
factory.setHost(properties.getProperty("connector.host"));		factory.setHost(properties.getProperty("connector.host"));
factory.setPort(		factory.setPort(
Integer.valueOf(properties.getProperty("connector.port"))		Integer.parseInt(properties.getProperty("connector.port"))
);		);
factory.setUsername(properties.getProperty("connector.username"));		factory.setUsername(properties.getProperty("connector.username"));
factory.setPassword(properties.getProperty("connector.password"));		factory.setPassword(properties.getProperty("connector.password"));
try {		try {
connection = factory.newConnection();		connection = factory.newConnection();
channel = connection.createChannel();		channel = connection.createChannel();
channel.queueDeclare(properties.getProperty("connector.queue-name"),		channel.queueDeclare(properties.getProperty("connector.queue-name"),
false, false, false, null);		false, false, false, null);
channel.basicConsume(		channel.basicConsume(
End of changes. 1 change blocks.
1 lines changed or deleted		1 lines changed or added

---