activemq-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Jake Choi ...@yahoo-inc.com>
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();
        policyEntry.setPendingDurableSubscriberPolicy(new
StorePendingDurableSubscriberMessageStoragePolicy() {
            @Override
            public PendingMessageCursor
getSubscriberPendingMessageCursor(Broker broker, String clientId, String
name,
                    int maxBatchSize, DurableTopicSubscription sub) {
                StoreDurableSubscriberCursor cursor =
(StoreDurableSubscriberCursor) super
                        .getSubscriberPendingMessageCursor(broker, clientId,
name, maxBatchSize, sub);
                // there's no #setNonPersistent(PendingMessageCursor
cursor);
                // so, how to replace "nonPersistent" from
FilePendingMessageCursor to VM- here?
                return cursor;
            }
        });

Any other way?



--
View this message in context: http://activemq.2283324.n4.nabble.com/How-to-configure-this-combination-of-queue-cursors-tp4670003p4670026.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.

Mime
View raw message