summaryrefslogtreecommitdiff
path: root/dotnet/Qpid.Client/Client/BasicMessageConsumer.cs
diff options
context:
space:
mode:
Diffstat (limited to 'dotnet/Qpid.Client/Client/BasicMessageConsumer.cs')
-rw-r--r--dotnet/Qpid.Client/Client/BasicMessageConsumer.cs10
1 files changed, 9 insertions, 1 deletions
diff --git a/dotnet/Qpid.Client/Client/BasicMessageConsumer.cs b/dotnet/Qpid.Client/Client/BasicMessageConsumer.cs
index 6fee316cb4..fdac5e75f2 100644
--- a/dotnet/Qpid.Client/Client/BasicMessageConsumer.cs
+++ b/dotnet/Qpid.Client/Client/BasicMessageConsumer.cs
@@ -44,6 +44,13 @@ namespace Apache.Qpid.Client
get { return _exclusive; }
}
+ private bool _browse;
+
+ public bool Browse
+ {
+ get { return _browse; }
+ }
+
public bool NoLocal
{
get { return _noLocal; }
@@ -131,7 +138,7 @@ namespace Apache.Qpid.Client
internal BasicMessageConsumer(ushort channelId, string queueName, bool noLocal,
MessageFactoryRegistry messageFactory, AmqChannel channel,
- int prefetchHigh, int prefetchLow, bool exclusive)
+ int prefetchHigh, int prefetchLow, bool exclusive, bool browse)
{
_channelId = channelId;
_queueName = queueName;
@@ -142,6 +149,7 @@ namespace Apache.Qpid.Client
_prefetchHigh = prefetchHigh;
_prefetchLow = prefetchLow;
_exclusive = exclusive;
+ _browse = browse;
if (_acknowledgeMode == AcknowledgeMode.SessionTransacted)
{