package com.sandu.ximon.admin.manager.iot.amqp;
|
|
import org.apache.qpid.jms.JmsConnectionListener;
|
import org.apache.qpid.jms.message.JmsInboundMessageDispatch;
|
|
import javax.jms.MessageConsumer;
|
import javax.jms.MessageProducer;
|
import javax.jms.Session;
|
import java.net.URI;
|
|
/**
|
* @author chenjiantian
|
* @date 2021/12/2 17:31
|
*/
|
public class AmqpConnectionListener implements JmsConnectionListener {
|
@Override
|
public void onConnectionEstablished(URI uri) {
|
|
}
|
|
@Override
|
public void onConnectionFailure(Throwable throwable) {
|
|
}
|
|
@Override
|
public void onConnectionInterrupted(URI uri) {
|
|
}
|
|
@Override
|
public void onConnectionRestored(URI uri) {
|
|
}
|
|
@Override
|
public void onInboundMessage(JmsInboundMessageDispatch jmsInboundMessageDispatch) {
|
|
}
|
|
@Override
|
public void onSessionClosed(Session session, Throwable throwable) {
|
|
}
|
|
@Override
|
public void onConsumerClosed(MessageConsumer messageConsumer, Throwable throwable) {
|
|
}
|
|
@Override
|
public void onProducerClosed(MessageProducer messageProducer, Throwable throwable) {
|
|
}
|
}
|
