activemq-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Jake Choi>
Subject Re: How to configure this combination of queue cursors?
Date Thu, 01 Aug 2013 22:11:01 GMT
Now, I want to do the same for the durable topic subscription but looks not
possible at this time, unlike the queue case: 

        PolicyEntry policyEntry = new PolicyEntry();
StorePendingDurableSubscriberMessageStoragePolicy() {
            public PendingMessageCursor
getSubscriberPendingMessageCursor(Broker broker, String clientId, String
                    int maxBatchSize, DurableTopicSubscription sub) {
                StoreDurableSubscriberCursor cursor =
(StoreDurableSubscriberCursor) super
                        .getSubscriberPendingMessageCursor(broker, clientId,
name, maxBatchSize, sub);
                // there's no #setNonPersistent(PendingMessageCursor
                // so, how to replace "nonPersistent" from
FilePendingMessageCursor to VM- here?
                return cursor;

Any other way?

View this message in context:
Sent from the ActiveMQ - User mailing list archive at

View raw message