🎄 Happy Holidays! 🥳
Most of Solace is closed December 24–January 1 so our employees can spend time with their families. We will re-open Thursday, January 2, 2024. Please expect slower response times during this period and open a support ticket for anything needing immediate assistance.
Happy Holidays!
Please note: most of Solace is closed December 25–January 2, and will re-open Tuesday, January 3, 2023.
Topic Endpoint Replay
Best Answers
-
Hi amishra,
Take a look at our Java Replay tutorial here: https://solace.com/samples/solace-samples-java/feature_message-replay/
It replays to a queue, but replaying to a topic is very similar.You should be able to just pull out the queue specific stuff and replace with a TopicEndpoint that's subscribed to a topic.
So remove this...
Queue queue = JCSMPFactory.onlyInstance().createQueue(queueName); consumerFlowProps.setEndpoint(queue);
Replace with this as an example
TopicEndpoint topicEndpoint = JCSMPFactory.onlyInstance().createDurableTopicEndpointEx(topicName); Topic topicSub = JCSMPFactory.onlyInstance().createTopic("ATTENDEE/tweets/stream"); consumerFlowProps.setEndpoint(topicEndpoint); consumerFlowProps.setNewSubscription(topicSub);Hope that helps!
6 -
As a side note, we usually recommend that clients use queue endpoints instead of topic endpoints as they are more flexible.
Topic endpoints allow you to specify an inbound message selector, but if you aren't using that feature then going with a queue endpoint will allow for your endpoint to have multiple topic subscriptions, choose exclusive vs. non-exclusive to provide, etc. You can read more the endpoints in the docs here: https://docs.solace.com/PubSub-Basics/Endpoints.htm5
Answers
-
Hi amishra,
Take a look at our Java Replay tutorial here: https://solace.com/samples/solace-samples-java/feature_message-replay/
It replays to a queue, but replaying to a topic is very similar.You should be able to just pull out the queue specific stuff and replace with a TopicEndpoint that's subscribed to a topic.
So remove this...
Queue queue = JCSMPFactory.onlyInstance().createQueue(queueName); consumerFlowProps.setEndpoint(queue);
Replace with this as an example
TopicEndpoint topicEndpoint = JCSMPFactory.onlyInstance().createDurableTopicEndpointEx(topicName); Topic topicSub = JCSMPFactory.onlyInstance().createTopic("ATTENDEE/tweets/stream"); consumerFlowProps.setEndpoint(topicEndpoint); consumerFlowProps.setNewSubscription(topicSub);Hope that helps!
6 -
As a side note, we usually recommend that clients use queue endpoints instead of topic endpoints as they are more flexible.
Topic endpoints allow you to specify an inbound message selector, but if you aren't using that feature then going with a queue endpoint will allow for your endpoint to have multiple topic subscriptions, choose exclusive vs. non-exclusive to provide, etc. You can read more the endpoints in the docs here: https://docs.solace.com/PubSub-Basics/Endpoints.htm5
