summaryrefslogtreecommitdiff
path: root/trunk/qpid/dotnet/Qpid.Messaging/MessageConsumerBuilder.cs
diff options
context:
space:
mode:
Diffstat (limited to 'trunk/qpid/dotnet/Qpid.Messaging/MessageConsumerBuilder.cs')
-rw-r--r--trunk/qpid/dotnet/Qpid.Messaging/MessageConsumerBuilder.cs105
1 files changed, 0 insertions, 105 deletions
diff --git a/trunk/qpid/dotnet/Qpid.Messaging/MessageConsumerBuilder.cs b/trunk/qpid/dotnet/Qpid.Messaging/MessageConsumerBuilder.cs
deleted file mode 100644
index fbf94d7c27..0000000000
--- a/trunk/qpid/dotnet/Qpid.Messaging/MessageConsumerBuilder.cs
+++ /dev/null
@@ -1,105 +0,0 @@
-/*
- *
- * Licensed to the Apache Software Foundation (ASF) under one
- * or more contributor license agreements. See the NOTICE file
- * distributed with this work for additional information
- * regarding copyright ownership. The ASF licenses this file
- * to you under the Apache License, Version 2.0 (the
- * "License"); you may not use this file except in compliance
- * with the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing,
- * software distributed under the License is distributed on an
- * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
- * KIND, either express or implied. See the License for the
- * specific language governing permissions and limitations
- * under the License.
- *
- */
-namespace Apache.Qpid.Messaging
-{
- /// <summary>
- /// MessageConsumerBuilder provides a builder with a fluent interface to assist with creating message consumers on a channel.
- ///
- /// <p/><table id="crc"><caption>CRC Card</caption>
- /// <tr><th> Responsibilities <th> Collaborations
- /// <tr><td> Create message consumers from consume parameters. <td> <see cref="IChannel">
- /// </table>
- /// </summary>
- ///
- /// <remarks>It may be better to replace the Create method with a DeclareBindAndCreate method, that declares and binds the consumers queue,
- /// as well as creating the consumer. This is a common use case, so the method will generally be usefull. Need to consider situations where
- /// the declare and bind is not to be done, for example when resubscribing to a durable subscription. There may be others too.</remarks>
- public class MessageConsumerBuilder
- {
- private bool _noLocal = false;
-
- private bool _exclusive = false;
-
- //private bool _durable = false;
- //private string _subscriptionName = null;
-
- private IChannel _channel;
-
- private readonly string _queueName;
-
- private int _prefetchLow;
-
- private int _prefetchHigh;
-
- public MessageConsumerBuilder(IChannel channel, string queueName)
- {
- _channel = channel;
- _queueName = queueName;
- _prefetchHigh = _channel.DefaultPrefetchHigh;
- _prefetchLow = _channel.DefaultPrefetchLow;
- }
-
- public MessageConsumerBuilder WithPrefetchLow(int prefetchLow)
- {
- _prefetchLow = prefetchLow;
- return this;
- }
-
- public MessageConsumerBuilder WithPrefetchHigh(int prefetchHigh)
- {
- _prefetchHigh = prefetchHigh;
- return this;
- }
-
- public MessageConsumerBuilder WithNoLocal(bool noLocal)
- {
- _noLocal = noLocal;
- return this;
- }
-
- public MessageConsumerBuilder WithExclusive(bool exclusive)
- {
- _exclusive = exclusive;
- return this;
- }
-
- /*
- public MessageConsumerBuilder WithDurable(bool durable)
- {
- _durable = durable;
- return this;
- }
- */
-
- /*
- public MessageConsumerBuilder WithSubscriptionName(string subscriptionName)
- {
- _subscriptionName = subscriptionName;
- return this;
- }
- */
-
- public IMessageConsumer Create()
- {
- return _channel.CreateConsumer(_queueName, _prefetchLow, _prefetchHigh, _noLocal, _exclusive);
- }
- }
-}