Мне нужен брокер, чтобы удалить все сообщения, которые не имеют ожидающих потребителей. Кажется, я помню, что это должно быть поведение по умолчанию, не так ли?Как автоматически истекать сообщения, которые не имеют потребителя?
Существует два утверждения, позволяющие определить время жизни для сообщений ativeMQ, если в течение этого периода времени сообщение не потребляется, оно истекает.
вы можете иметь два подхода к этой
producer.setTimeToLive(Long timeToLiveInMilliSeconds)
Описанный выше подход будет применяться ко всем сообщениям от этого производителя, или если вы хотите для конкретных сообщений, которые вы можете сделать это, как этот
producer.send(Destination destination,Message message,int deliveryMode,int priority,long timeToLive)
помимо это отсутствие конфигурации по умолчанию, которое сообщение удаляется, как только оно помещается в очередь, и нет потребителя для этой очереди
надеюсь, что это поможет!
Удачи вам!
hm Странно, я должен был забыть об этом поведении. Да, я знал о времени, чтобы жить, но, я думаю, мне нужна функция, где, если нет открытого подключения tcp к потребителю на стороне брокера, он должен немедленно отказаться от этого сообщения для этой очереди. – Blub
Возможно, вы можете использовать код Java для его достижения – Vihar