Mailing-List: contact users-help@activemq.apache.org; run by ezmlm
Precedence: bulk
Reply-To: users@activemq.apache.org
Received-SPF: neutral (nike.apache.org: 216.139.250.139 is neither permitted
 nor denied by domain of jw@yahoo-inc.com)
Date: Thu, 1 Aug 2013 15:11:01 -0700 (PDT)
From: Jake Choi <jw@yahoo-inc.com>
To: users@activemq.apache.org
Message-ID: <1375395061212-4670026.post@n4.nabble.com>
In-Reply-To: 
 <CAKS7T5Oc2RaNBy-kz176CPYdkF-36mpk8CTZGTFHMnYT7eqGvQ@mail.gmail.com>
References: <1375376342750-4670003.post@n4.nabble.com>
 <CAKS7T5PG94jKw8X0vj1vjwLj4cWTPUVuhG1HF46ovthp5DpLHg@mail.gmail.com>
 <1375379145026-4670005.post@n4.nabble.com>
 <CAKS7T5Oc2RaNBy-kz176CPYdkF-36mpk8CTZGTFHMnYT7eqGvQ@mail.gmail.com>
Subject: Re: How to configure this combination of queue cursors?
MIME-Version: 1.0
Content-Type: text/plain; charset=us-ascii
Content-Transfer-Encoding: 7bit

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.