Skip to content

Commit d3f84b1

Browse files
author
Simon MacMullen
committed
Merge bug22772 into amqp_0_9_1.
2 parents 9c8b41b + 2f17442 commit d3f84b1

35 files changed

+854
-647
lines changed

RabbitMQDotNetClient.sln

Lines changed: 9 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -60,6 +60,8 @@ Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "RabbitMQ.Client.Examples.Sh
6060
EndProject
6161
Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "RabbitMQ.Client.Examples.PerfTest", "projects\examples\client\PerfTest\RabbitMQ.Client.Examples.PerfTest.csproj", "{6ED176D6-B789-4673-8300-CB671962FE00}"
6262
EndProject
63+
Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "RabbitMQ.Client.Examples.Subscriber", "projects\examples\client\Subscriber\RabbitMQ.Client.Examples.Subscriber.csproj", "{F6DF1899-A038-4DBF-86D0-0DE64F2422EC}"
64+
EndProject
6365
Global
6466
GlobalSection(SolutionConfigurationPlatforms) = preSolution
6567
Debug|Any CPU = Debug|Any CPU
@@ -192,6 +194,12 @@ Global
192194
{6ED176D6-B789-4673-8300-CB671962FE00}.DebugNoTest|Any CPU.Build.0 = Debug|Any CPU
193195
{6ED176D6-B789-4673-8300-CB671962FE00}.Release|Any CPU.ActiveCfg = Release|Any CPU
194196
{6ED176D6-B789-4673-8300-CB671962FE00}.Release|Any CPU.Build.0 = Release|Any CPU
197+
{F6DF1899-A038-4DBF-86D0-0DE64F2422EC}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
198+
{F6DF1899-A038-4DBF-86D0-0DE64F2422EC}.Debug|Any CPU.Build.0 = Debug|Any CPU
199+
{F6DF1899-A038-4DBF-86D0-0DE64F2422EC}.DebugNoTest|Any CPU.ActiveCfg = Debug|Any CPU
200+
{F6DF1899-A038-4DBF-86D0-0DE64F2422EC}.DebugNoTest|Any CPU.Build.0 = Debug|Any CPU
201+
{F6DF1899-A038-4DBF-86D0-0DE64F2422EC}.Release|Any CPU.ActiveCfg = Release|Any CPU
202+
{F6DF1899-A038-4DBF-86D0-0DE64F2422EC}.Release|Any CPU.Build.0 = Release|Any CPU
195203
EndGlobalSection
196204
GlobalSection(SolutionProperties) = preSolution
197205
HideSolutionNode = FALSE
@@ -219,6 +227,7 @@ Global
219227
{44D14FF0-1015-4AAA-ABCA-BF611879816C} = {78D13AD2-B1AC-442C-95C8-958D643FC40B}
220228
{8BCE15DB-C92F-4FA4-AE57-9CA73DE91EB2} = {78D13AD2-B1AC-442C-95C8-958D643FC40B}
221229
{6ED176D6-B789-4673-8300-CB671962FE00} = {78D13AD2-B1AC-442C-95C8-958D643FC40B}
230+
{F6DF1899-A038-4DBF-86D0-0DE64F2422EC} = {78D13AD2-B1AC-442C-95C8-958D643FC40B}
222231
{20E34D9F-EE72-4B55-B6FE-1D0DBE5B74CD} = {EA42A7EF-7CE6-4EDA-98EA-6675C7EF7F69}
223232
{39CA1299-1F9E-452E-AA00-4BF874944B1E} = {EA42A7EF-7CE6-4EDA-98EA-6675C7EF7F69}
224233
{201B37E1-9BFC-4A01-9760-30C5BB19CFE3} = {20E34D9F-EE72-4B55-B6FE-1D0DBE5B74CD}

docs/specs/amqp0-9-1.stripped.xml

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -329,7 +329,7 @@ THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
329329
<field name="type" domain="shortstr"/>
330330
<field name="user-id" domain="shortstr"/>
331331
<field name="app-id" domain="shortstr"/>
332-
<field name="reserved" domain="shortstr"/>
332+
<field name="cluster-id" domain="shortstr"/>
333333
<method name="qos" synchronous="1" index="10">
334334
<chassis name="server" implement="MUST"/>
335335
<response name="qos-ok"/>

docs/wikipages/data.ApiOverview.txt

Lines changed: 12 additions & 15 deletions
Original file line numberDiff line numberDiff line change
@@ -119,24 +119,21 @@ The following code connects to an AMQP broker:
119119

120120
@code java
121121
ConnectionFactory factory = new ConnectionFactory();
122-
IProtocol protocol = Protocols.FromEnvironment();
123-
IConnection conn = factory.CreateConnection(protocol, hostName, portNumber);
124-
125-
The default parameters are:
122+
factory.UserName = user;
123+
factory.Password = pass;
124+
factory.VirtualHost = vhost;
125+
factory.Protocol = Protocols.FromEnvironment();
126+
factory.HostName = hostName;
127+
factory.Port = AmqpTcpEndpoint.UseDefaultPort;
128+
IConnection conn = factory.CreateConnection();
129+
130+
All factory properties have default values. The default value for a property will be used if the property remains unassigned prior to creating a connection:
126131
- username: [code "guest"]
127132
- password: [code "guest"]
128133
- virtual-host: [code "/"]
129-
130-
For control over the username, password and virtual-host supplied to
131-
the broker, modify the [code ConnectionFactory]'s [code
132-
ConnectionParameters] object before calling [code CreateConnection]:
133-
134-
@code java
135-
ConnectionParameters params = factory.Parameters;
136-
params.UserName = userName;
137-
params.Password = password;
138-
params.VirtualHost = virtualHost;
139-
IConnection conn = factory.CreateConnection(protocol, hostName, portNumber);
134+
- protocol: [code AMQP 0.8]
135+
- hostname: [code localhost]
136+
- port: [code 5672]
140137

141138
The IConnection interface can then be used to open a channel:
142139

docs/wikipages/data.MessagingPatterns.txt

Lines changed: 7 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -382,22 +382,22 @@ on class [code RabbitMQ.Client.IModel].
382382

383383
The class [code RabbitMQ.Client.MessagePatterns.Subscription]
384384
implements most of the boilerplate of receiving messages (including,
385-
in particular, broadcast events) for you, including queue and exchange
386-
declaration and queue binding, as well as consumer declaration and
387-
management. For example,
385+
in particular, broadcast events) for you, including consumer
386+
declaration and management, but excluding queue and exchange
387+
declaration and queue binding. For example,
388388

389389
@code java
390390
// "IModel ch" in scope.
391-
Subscription sub = new Subscription(ch, "price", "topic", "STOCK.IBM.#");
391+
Subscription sub = new Subscription(ch, "STOCK.IBM.#");
392392
foreach (BasicDeliverEventArgs e in sub) {
393393
// handle the message contained in e ...
394394
// ... and finally acknowledge it
395395
sub.Ack(e);
396396
}
397397

398-
will declare the relevant exchange, declare a temporary queue, bind
399-
the two together, and start a consumer on the queue using [code
400-
IModel.BasicConsume].
398+
will start a consumer on the queue using [code IModel.BasicConsume].
399+
It is assumed that the queue and any bindings have been previously
400+
declared.
401401

402402
[code Subscription.Ack()] should be called for each received event,
403403
whether or not auto-acknowledgement mode is used, because [code

docs/wikipages/data.UserGuide.txt

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -13,9 +13,9 @@ NDocProc-generated javadoc-like HTML documentation.
1313
** AMQP dialects implemented
1414

1515
The client library implements AMQP specifications version 0-8, 0-8bis
16-
(0-8 as modified by QPid for their M2 release) and 0-9 (omitting
16+
(0-8 as modified by QPid for their M2 release), 0-9 (omitting
1717
sections of the specification marked "work in progress", i.e. the
18-
[code Message] content-class). The ApiGen tool processes the
18+
[code Message] content-class) and 0-9-1. The ApiGen tool processes the
1919
specification XML files in conjunction with certain C# interfaces,
2020
generating C# code directly, which is compiled into the final
2121
assembly.

docs/wikipages/meta.ApiOverview.txt

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,5 +1,5 @@
11
owner:
2-
timestamp: Thu, 24 Jan 2008 17:47:23 GMT
2+
timestamp: Mon, 05 Jul 2010 13:15:32 GMT
33
author:
44
editgroup:
55
viewgroup:

projects/client/Apigen/src/apigen/AmqpField.cs

Lines changed: 0 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -70,13 +70,5 @@ public string Domain {
7070
return result;
7171
}
7272
}
73-
74-
public bool Reserved
75-
{
76-
get
77-
{
78-
return GetString("@reserved", "") == "1";
79-
}
80-
}
8173
}
8274
}

0 commit comments

Comments
 (0)