Skip to content

HTTPS clone URL

Subversion checkout URL

You can clone with
or
.
Download ZIP
Browse files

Updated samples

  • Loading branch information...
commit e62c9938e98cbb8a76a310338a6faab3ed1846aa 1 parent be19e51
@DonMcRae DonMcRae authored
Showing with 544,174 additions and 256 deletions.
  1. +20 −1 Spring.Amqp.HelloWorld/Spring.Amqp.HelloWorld.BrokerConfiguration/Program.cs
  2. +22 −21 ...elloWorld/Spring.Amqp.HelloWorld.BrokerConfiguration/Spring.Amqp.HelloWorld.BrokerConfiguration.2010.csproj
  3. +17 −0 .../Spring.Amqp.HelloWorld.BrokerConfiguration/bin/Debug/Spring.Amqp.HelloWorld.BrokerConfiguration.exe.config
  4. BIN  .../Spring.Amqp.HelloWorld.BrokerConfiguration/bin/Debug/Spring.Amqp.HelloWorld.BrokerConfiguration.vshost.exe
  5. +17 −0 ....Amqp.HelloWorld.BrokerConfiguration/bin/Debug/Spring.Amqp.HelloWorld.BrokerConfiguration.vshost.exe.config
  6. +11 −0 ...mqp.HelloWorld.BrokerConfiguration/bin/Debug/Spring.Amqp.HelloWorld.BrokerConfiguration.vshost.exe.manifest
  7. BIN  ...loWorld/Spring.Amqp.HelloWorld.BrokerConfiguration/obj/Debug/DesignTimeResolveAssemblyReferencesInput.cache
  8. +1 −0  ...d.BrokerConfiguration/obj/Debug/Spring.Amqp.HelloWorld.BrokerConfiguration.2010.csproj.FileListAbsolute.txt
  9. 0  ...HelloWorld/Spring.Amqp.HelloWorld.Consumer.Async/{Spring.Amqp.HelloWorld.Consumer.Async → }/App.config
  10. 0  ...pring.Amqp.HelloWorld.Consumer.Async/{Spring.Amqp.HelloWorld.Consumer.Async → }/Config/Application.xml
  11. 0  .../Spring.Amqp.HelloWorld.Consumer.Async/{Spring.Amqp.HelloWorld.Consumer.Async → }/HelloWorldHandler.cs
  12. +20 −1 ...HelloWorld/Spring.Amqp.HelloWorld.Consumer.Async/{Spring.Amqp.HelloWorld.Consumer.Async → }/Program.cs
  13. 0  ...g.Amqp.HelloWorld.Consumer.Async/{Spring.Amqp.HelloWorld.Consumer.Async → }/Properties/AssemblyInfo.cs
  14. +18 −13 ...mer.Async/{Spring.Amqp.HelloWorld.Consumer.Async → }/Spring.Amqp.HelloWorld.Consumer.Async.2010.csproj
  15. BIN  ...HelloWorld/Spring.Amqp.HelloWorld.Consumer.Async/bin/Debug/Spring.Amqp.HelloWorld.Consumer.Async.vshost.exe
  16. +50 −0 ...rld/Spring.Amqp.HelloWorld.Consumer.Async/bin/Debug/Spring.Amqp.HelloWorld.Consumer.Async.vshost.exe.config
  17. +11 −0 ...d/Spring.Amqp.HelloWorld.Consumer.Async/bin/Debug/Spring.Amqp.HelloWorld.Consumer.Async.vshost.exe.manifest
  18. BIN  ...p.HelloWorld/Spring.Amqp.HelloWorld.Consumer.Async/obj/Debug/DesignTimeResolveAssemblyReferencesInput.cache
  19. 0  ...World/Spring.Amqp.HelloWorld.Consumer.Async/{Spring.Amqp.HelloWorld.Consumer.Async → }/packages.config
  20. +15 −13 Spring.Amqp.HelloWorld/Spring.Amqp.HelloWorld.Consumer/Spring.Amqp.HelloWorld.Consumer.2010.csproj
  21. BIN  Spring.Amqp.HelloWorld/Spring.Amqp.HelloWorld.Consumer/bin/Debug/Spring.Amqp.HelloWorld.Consumer.vshost.exe
  22. +51 −0 ...Amqp.HelloWorld/Spring.Amqp.HelloWorld.Consumer/bin/Debug/Spring.Amqp.HelloWorld.Consumer.vshost.exe.config
  23. +11 −0 ...qp.HelloWorld/Spring.Amqp.HelloWorld.Consumer/bin/Debug/Spring.Amqp.HelloWorld.Consumer.vshost.exe.manifest
  24. BIN  ...ng.Amqp.HelloWorld/Spring.Amqp.HelloWorld.Consumer/obj/Debug/DesignTimeResolveAssemblyReferencesInput.cache
  25. +20 −1 Spring.Amqp.HelloWorld/Spring.Amqp.HelloWorld.Producer.Async/Program.cs
  26. +13 −14 Spring.Amqp.HelloWorld/Spring.Amqp.HelloWorld.Producer.Async/Spring.Amqp.HelloWorld.Producer.Async.2010.csproj
  27. BIN  ...HelloWorld/Spring.Amqp.HelloWorld.Producer.Async/bin/Debug/Spring.Amqp.HelloWorld.Producer.Async.vshost.exe
  28. +51 −0 ...rld/Spring.Amqp.HelloWorld.Producer.Async/bin/Debug/Spring.Amqp.HelloWorld.Producer.Async.vshost.exe.config
  29. +11 −0 ...d/Spring.Amqp.HelloWorld.Producer.Async/bin/Debug/Spring.Amqp.HelloWorld.Producer.Async.vshost.exe.manifest
  30. BIN  ...p.HelloWorld/Spring.Amqp.HelloWorld.Producer.Async/obj/Debug/DesignTimeResolveAssemblyReferencesInput.cache
  31. +15 −13 Spring.Amqp.HelloWorld/Spring.Amqp.HelloWorld.Producer/Spring.Amqp.HelloWorld.Producer.2010.csproj
  32. BIN  Spring.Amqp.HelloWorld/Spring.Amqp.HelloWorld.Producer/bin/Debug/Spring.Amqp.HelloWorld.Producer.vshost.exe
  33. +51 −0 ...Amqp.HelloWorld/Spring.Amqp.HelloWorld.Producer/bin/Debug/Spring.Amqp.HelloWorld.Producer.vshost.exe.config
  34. +11 −0 ...qp.HelloWorld/Spring.Amqp.HelloWorld.Producer/bin/Debug/Spring.Amqp.HelloWorld.Producer.vshost.exe.manifest
  35. BIN  ...ng.Amqp.HelloWorld/Spring.Amqp.HelloWorld.Producer/obj/Debug/DesignTimeResolveAssemblyReferencesInput.cache
  36. +0 −44 Spring.RabbitQuickStart/Spring.RabbitQuickStart.2010.sln
  37. +35 −6 Spring.RabbitQuickStart/src/Spring/Spring.RabbitQuickStart.BrokerConfiguration/Program.cs
  38. +25 −21 .../Spring/Spring.RabbitQuickStart.BrokerConfiguration/Spring.RabbitQuickStart.BrokerConfiguration.2010.csproj
  39. +9 −0 Spring.RabbitQuickStart/src/Spring/Spring.RabbitQuickStart.BrokerConfiguration/app.config
  40. +0 −5 Spring.RabbitQuickStart/src/Spring/Spring.RabbitQuickStart.Client/Config/Messaging.xml
  41. +31 −0 Spring.RabbitQuickStart/src/Spring/Spring.RabbitQuickStart.Client/Gateways/IStockServiceGateway.cs
  42. +24 −12 Spring.RabbitQuickStart/src/Spring/Spring.RabbitQuickStart.Client/Gateways/RabbitStockServiceGateway.cs
  43. +9 −6 Spring.RabbitQuickStart/src/Spring/Spring.RabbitQuickStart.Client/Handlers/StockAppHandler.cs
  44. +0 −5 Spring.RabbitQuickStart/src/Spring/Spring.RabbitQuickStart.Client/Program.cs
  45. +14 −17 Spring.RabbitQuickStart/src/Spring/Spring.RabbitQuickStart.Client/Spring.RabbitQuickStart.Client.2010.csproj
  46. +8 −5 Spring.RabbitQuickStart/src/Spring/Spring.RabbitQuickStart.Client/UI/StockController.cs
  47. +87 −3 Spring.RabbitQuickStart/src/Spring/Spring.RabbitQuickStart.Client/UI/StockForm.cs
  48. +100 −16 Spring.RabbitQuickStart/src/Spring/Spring.RabbitQuickStart.Client/UI/StockForm.designer.cs
  49. +2 −2 Spring.RabbitQuickStart/src/Spring/Spring.RabbitQuickStart.Client/UI/StockForm.resx
  50. BIN  ...bitQuickStart/src/Spring/Spring.RabbitQuickStart.Client/bin/Debug/Spring.RabbitQuickStart.Client.vshost.exe
  51. +61 −0 ...kStart/src/Spring/Spring.RabbitQuickStart.Client/bin/Debug/Spring.RabbitQuickStart.Client.vshost.exe.config
  52. +11 −0 ...tart/src/Spring/Spring.RabbitQuickStart.Client/bin/Debug/Spring.RabbitQuickStart.Client.vshost.exe.manifest
  53. BIN  ...ickStart/src/Spring/Spring.RabbitQuickStart.Client/obj/Debug/DesignTimeResolveAssemblyReferencesInput.cache
  54. +65 −0 Spring.RabbitQuickStart/src/Spring/Spring.RabbitQuickStart.Common/Data/Quote.cs
  55. +50 −0 Spring.RabbitQuickStart/src/Spring/Spring.RabbitQuickStart.Common/Data/Stock.cs
  56. +32 −0 Spring.RabbitQuickStart/src/Spring/Spring.RabbitQuickStart.Common/Data/StockExchange.cs
  57. +1 −0  Spring.RabbitQuickStart/src/Spring/Spring.RabbitQuickStart.Common/Data/TradeRequest.cs
  58. +2 −1  Spring.RabbitQuickStart/src/Spring/Spring.RabbitQuickStart.Common/Data/TradeResponse.cs
  59. +3 −0  Spring.RabbitQuickStart/src/Spring/Spring.RabbitQuickStart.Common/Spring.RabbitQuickStart.Common.2010.csproj
  60. BIN  ...ickStart/src/Spring/Spring.RabbitQuickStart.Common/obj/Debug/DesignTimeResolveAssemblyReferencesInput.cache
  61. +3 −6 Spring.RabbitQuickStart/src/Spring/Spring.RabbitQuickStart.Server/Config/Messaging.xml
  62. +28 −0 Spring.RabbitQuickStart/src/Spring/Spring.RabbitQuickStart.Server/Gateways/IMarketDataGateway.cs
  63. +130 −0 Spring.RabbitQuickStart/src/Spring/Spring.RabbitQuickStart.Server/Gateways/MarketDataGateway.cs
  64. +19 −0 Spring.RabbitQuickStart/src/Spring/Spring.RabbitQuickStart.Server/Handlers/LoggingExceptionListener.cs
  65. +23 −0 Spring.RabbitQuickStart/src/Spring/Spring.RabbitQuickStart.Server/Handlers/StockAppHandler.cs
  66. +29 −7 Spring.RabbitQuickStart/src/Spring/Spring.RabbitQuickStart.Server/Program.cs
  67. +0 −2  Spring.RabbitQuickStart/src/Spring/Spring.RabbitQuickStart.Server/Services/ICreditCheckService.cs
  68. +0 −2  Spring.RabbitQuickStart/src/Spring/Spring.RabbitQuickStart.Server/Services/IExecutionVenueService.cs
  69. +0 −2  Spring.RabbitQuickStart/src/Spring/Spring.RabbitQuickStart.Server/Services/ITradingService.cs
  70. +19 −0 Spring.RabbitQuickStart/src/Spring/Spring.RabbitQuickStart.Server/Services/Stubs/CreditCheckServiceStub.cs
  71. +19 −0 Spring.RabbitQuickStart/src/Spring/Spring.RabbitQuickStart.Server/Services/Stubs/ExecutionVenueServiceStub.cs
  72. +19 −0 Spring.RabbitQuickStart/src/Spring/Spring.RabbitQuickStart.Server/Services/Stubs/TradingServiceStub.cs
  73. +15 −17 Spring.RabbitQuickStart/src/Spring/Spring.RabbitQuickStart.Server/Spring.RabbitQuickStart.Server.2010.csproj
  74. BIN  ...bitQuickStart/src/Spring/Spring.RabbitQuickStart.Server/bin/Debug/Spring.RabbitQuickStart.Server.vshost.exe
  75. +62 −0 ...kStart/src/Spring/Spring.RabbitQuickStart.Server/bin/Debug/Spring.RabbitQuickStart.Server.vshost.exe.config
  76. +11 −0 ...tart/src/Spring/Spring.RabbitQuickStart.Server/bin/Debug/Spring.RabbitQuickStart.Server.vshost.exe.manifest
  77. BIN  ...ickStart/src/Spring/Spring.RabbitQuickStart.Server/obj/Debug/DesignTimeResolveAssemblyReferencesInput.cache
  78. BIN  packages/AutoMoq.1.5.0/AutoMoq.1.5.0.nupkg
  79. BIN  packages/AutoMoq.1.5.0/lib/AutoMoq.dll
  80. BIN  packages/Common.Logging.2.0.0/Common.Logging.2.0.0.nupkg
  81. BIN  packages/Common.Logging.2.0.0/lib/2.0/Common.Logging.dll
  82. BIN  packages/CommonServiceLocator.1.0/CommonServiceLocator.1.0.nupkg
  83. +280 −0 packages/CommonServiceLocator.1.0/lib/NET35/Microsoft.Practices.ServiceLocation.XML
  84. BIN  packages/CommonServiceLocator.1.0/lib/NET35/Microsoft.Practices.ServiceLocation.dll
  85. BIN  packages/CommonServiceLocator.1.0/lib/NET35/Microsoft.Practices.ServiceLocation.pdb
  86. +280 −0 packages/CommonServiceLocator.1.0/lib/SL30/Microsoft.Practices.ServiceLocation.XML
  87. BIN  packages/CommonServiceLocator.1.0/lib/SL30/Microsoft.Practices.ServiceLocation.dll
  88. BIN  packages/Erlang.NET.0.9.5/Erlang.NET.0.9.5.nupkg
  89. BIN  packages/Erlang.NET.0.9.5/lib/net20/Erlang.dll
  90. +39 −0 packages/Moq.4.0.10827/License.txt
  91. BIN  packages/Moq.4.0.10827/Moq.4.0.10827.nupkg
  92. BIN  packages/Moq.4.0.10827/Moq.chm
  93. BIN  packages/Moq.4.0.10827/lib/NET35/Moq.dll
  94. BIN  packages/Moq.4.0.10827/lib/NET35/Moq.pdb
  95. +5,768 −0 packages/Moq.4.0.10827/lib/NET35/Moq.xml
  96. BIN  packages/Moq.4.0.10827/lib/NET40/Moq.dll
  97. BIN  packages/Moq.4.0.10827/lib/NET40/Moq.pdb
  98. +5,120 −0 packages/Moq.4.0.10827/lib/NET40/Moq.xml
  99. BIN  packages/Moq.4.0.10827/lib/Silverlight4/Castle.Core.dll
  100. BIN  packages/Moq.4.0.10827/lib/Silverlight4/Moq.Silverlight.dll
  101. BIN  packages/Moq.4.0.10827/lib/Silverlight4/Moq.Silverlight.pdb
  102. +5,101 −0 packages/Moq.4.0.10827/lib/Silverlight4/Moq.Silverlight.xml
  103. BIN  packages/NUnit.2.5.10.11092/Logo.ico
  104. BIN  packages/NUnit.2.5.10.11092/NUnit.2.5.10.11092.nupkg
  105. +277 −0 packages/NUnit.2.5.10.11092/NUnitFitTests.html
  106. +342 −0 packages/NUnit.2.5.10.11092/fit-license.txt
  107. BIN  packages/NUnit.2.5.10.11092/lib/nunit.framework.dll
  108. +10,407 −0 packages/NUnit.2.5.10.11092/lib/nunit.framework.xml
  109. BIN  packages/NUnit.2.5.10.11092/lib/nunit.mocks.dll
  110. BIN  packages/NUnit.2.5.10.11092/lib/pnunit.framework.dll
  111. +15 −0 packages/NUnit.2.5.10.11092/license.txt
  112. +124 −0 packages/NUnit.2.5.10.11092/tools/NUnitTests.VisualState.xml
  113. +85 −0 packages/NUnit.2.5.10.11092/tools/NUnitTests.config
  114. +14 −0 packages/NUnit.2.5.10.11092/tools/NUnitTests.nunit
  115. +5,971 −0 packages/NUnit.2.5.10.11092/tools/TestResult.xml
  116. +4 −0 packages/NUnit.2.5.10.11092/tools/agent.conf
  117. +18 −0 packages/NUnit.2.5.10.11092/tools/agent.log.conf
  118. +18 −0 packages/NUnit.2.5.10.11092/tools/launcher.log.conf
  119. BIN  packages/NUnit.2.5.10.11092/tools/lib/Failure.png
  120. BIN  packages/NUnit.2.5.10.11092/tools/lib/Ignored.png
  121. BIN  packages/NUnit.2.5.10.11092/tools/lib/Inconclusive.png
  122. BIN  packages/NUnit.2.5.10.11092/tools/lib/Skipped.png
  123. BIN  packages/NUnit.2.5.10.11092/tools/lib/Success.png
  124. BIN  packages/NUnit.2.5.10.11092/tools/lib/fit.dll
  125. BIN  packages/NUnit.2.5.10.11092/tools/lib/log4net.dll
  126. BIN  packages/NUnit.2.5.10.11092/tools/lib/nunit-console-runner.dll
  127. BIN  packages/NUnit.2.5.10.11092/tools/lib/nunit-gui-runner.dll
  128. BIN  packages/NUnit.2.5.10.11092/tools/lib/nunit.core.dll
  129. BIN  packages/NUnit.2.5.10.11092/tools/lib/nunit.core.interfaces.dll
  130. BIN  packages/NUnit.2.5.10.11092/tools/lib/nunit.fixtures.dll
  131. BIN  packages/NUnit.2.5.10.11092/tools/lib/nunit.uiexception.dll
  132. BIN  packages/NUnit.2.5.10.11092/tools/lib/nunit.uikit.dll
  133. BIN  packages/NUnit.2.5.10.11092/tools/lib/nunit.util.dll
  134. BIN  packages/NUnit.2.5.10.11092/tools/nunit-agent-x86.exe
  135. +69 −0 packages/NUnit.2.5.10.11092/tools/nunit-agent-x86.exe.config
  136. BIN  packages/NUnit.2.5.10.11092/tools/nunit-agent.exe
  137. +69 −0 packages/NUnit.2.5.10.11092/tools/nunit-agent.exe.config
  138. BIN  packages/NUnit.2.5.10.11092/tools/nunit-console-x86.exe
  139. +69 −0 packages/NUnit.2.5.10.11092/tools/nunit-console-x86.exe.config
  140. BIN  packages/NUnit.2.5.10.11092/tools/nunit-console.exe
  141. +69 −0 packages/NUnit.2.5.10.11092/tools/nunit-console.exe.config
  142. BIN  packages/NUnit.2.5.10.11092/tools/nunit-x86.exe
  143. +83 −0 packages/NUnit.2.5.10.11092/tools/nunit-x86.exe.config
  144. BIN  packages/NUnit.2.5.10.11092/tools/nunit.exe
  145. +83 −0 packages/NUnit.2.5.10.11092/tools/nunit.exe.config
  146. BIN  packages/NUnit.2.5.10.11092/tools/nunit.framework.dll
  147. BIN  packages/NUnit.2.5.10.11092/tools/pnunit-agent.exe
  148. +77 −0 packages/NUnit.2.5.10.11092/tools/pnunit-agent.exe.config
  149. BIN  packages/NUnit.2.5.10.11092/tools/pnunit-launcher.exe
  150. +77 −0 packages/NUnit.2.5.10.11092/tools/pnunit-launcher.exe.config
  151. BIN  packages/NUnit.2.5.10.11092/tools/pnunit.framework.dll
  152. BIN  packages/NUnit.2.5.10.11092/tools/pnunit.tests.dll
  153. BIN  packages/NUnit.2.5.10.11092/tools/runFile.exe
  154. +43 −0 packages/NUnit.2.5.10.11092/tools/runFile.exe.config
  155. +2 −0  packages/NUnit.2.5.10.11092/tools/runpnunit.bat
  156. +24 −0 packages/NUnit.2.5.10.11092/tools/test.conf
  157. BIN  packages/Newtonsoft.Json.4.0.2/Newtonsoft.Json.4.0.2.nupkg
  158. BIN  packages/Newtonsoft.Json.4.0.2/lib/net20/Newtonsoft.Json.Net20.dll
  159. BIN  packages/Newtonsoft.Json.4.0.2/lib/net20/Newtonsoft.Json.Net20.pdb
  160. +6,520 −0 packages/Newtonsoft.Json.4.0.2/lib/net20/Newtonsoft.Json.Net20.xml
  161. BIN  packages/Newtonsoft.Json.4.0.2/lib/net35/Newtonsoft.Json.Net35.dll
  162. BIN  packages/Newtonsoft.Json.4.0.2/lib/net35/Newtonsoft.Json.Net35.pdb
  163. +6,711 −0 packages/Newtonsoft.Json.4.0.2/lib/net35/Newtonsoft.Json.Net35.xml
  164. BIN  packages/Newtonsoft.Json.4.0.2/lib/net40/Newtonsoft.Json.dll
  165. BIN  packages/Newtonsoft.Json.4.0.2/lib/net40/Newtonsoft.Json.pdb
  166. +6,862 −0 packages/Newtonsoft.Json.4.0.2/lib/net40/Newtonsoft.Json.xml
  167. BIN  packages/Newtonsoft.Json.4.0.2/lib/sl3-wp/Newtonsoft.Json.WindowsPhone.dll
  168. BIN  packages/Newtonsoft.Json.4.0.2/lib/sl3-wp/Newtonsoft.Json.WindowsPhone.pdb
  169. +6,331 −0 packages/Newtonsoft.Json.4.0.2/lib/sl3-wp/Newtonsoft.Json.WindowsPhone.xml
  170. BIN  packages/Newtonsoft.Json.4.0.2/lib/sl4/Newtonsoft.Json.Silverlight.dll
  171. BIN  packages/Newtonsoft.Json.4.0.2/lib/sl4/Newtonsoft.Json.Silverlight.pdb
  172. +6,361 −0 packages/Newtonsoft.Json.4.0.2/lib/sl4/Newtonsoft.Json.Silverlight.xml
  173. BIN  packages/RabbitMQ.Client.2.5.1/RabbitMQ.Client.2.5.1.nupkg
  174. BIN  packages/RabbitMQ.Client.2.5.1/lib/net20/RabbitMQ.Client.dll
  175. +7,281 −0 packages/RabbitMQ.Client.2.5.1/lib/net20/RabbitMQ.Client.xml
  176. BIN  packages/RabbitMQ.Client.2.5.1/lib/net30/RabbitMQ.Client.dll
  177. +7,281 −0 packages/RabbitMQ.Client.2.5.1/lib/net30/RabbitMQ.Client.xml
  178. BIN  packages/Spring.Aop.1.3.2/Spring.Aop.1.3.2.nupkg
  179. BIN  packages/Spring.Aop.1.3.2/lib/net11/Spring.Aop.dll
  180. BIN  packages/Spring.Aop.1.3.2/lib/net11/Spring.Aop.pdb
  181. +11,717 −0 packages/Spring.Aop.1.3.2/lib/net11/Spring.Aop.xml
  182. BIN  packages/Spring.Aop.1.3.2/lib/net20/Spring.Aop.dll
  183. BIN  packages/Spring.Aop.1.3.2/lib/net20/Spring.Aop.pdb
  184. +11,751 −0 packages/Spring.Aop.1.3.2/lib/net20/Spring.Aop.xml
  185. BIN  packages/Spring.Aop.1.3.2/lib/net30/Spring.Aop.dll
  186. BIN  packages/Spring.Aop.1.3.2/lib/net30/Spring.Aop.pdb
  187. +11,751 −0 packages/Spring.Aop.1.3.2/lib/net30/Spring.Aop.xml
  188. BIN  packages/Spring.Aop.1.3.2/lib/net35/Spring.Aop.dll
  189. BIN  packages/Spring.Aop.1.3.2/lib/net35/Spring.Aop.pdb
  190. +11,751 −0 packages/Spring.Aop.1.3.2/lib/net35/Spring.Aop.xml
  191. BIN  packages/Spring.Aop.1.3.2/lib/net40/Spring.Aop.dll
  192. BIN  packages/Spring.Aop.1.3.2/lib/net40/Spring.Aop.pdb
  193. +11,751 −0 packages/Spring.Aop.1.3.2/lib/net40/Spring.Aop.xml
  194. BIN  packages/Spring.Core.1.3.2/Spring.Core.1.3.2.nupkg
  195. BIN  packages/Spring.Core.1.3.2/lib/net11/Spring.Core.dll
  196. BIN  packages/Spring.Core.1.3.2/lib/net11/Spring.Core.pdb
  197. +47,381 −0 packages/Spring.Core.1.3.2/lib/net11/Spring.Core.xml
  198. BIN  packages/Spring.Core.1.3.2/lib/net20/Spring.Core.dll
  199. BIN  packages/Spring.Core.1.3.2/lib/net20/Spring.Core.pdb
  200. +49,291 −0 packages/Spring.Core.1.3.2/lib/net20/Spring.Core.xml
  201. BIN  packages/Spring.Core.1.3.2/lib/net30/Spring.Core.dll
  202. BIN  packages/Spring.Core.1.3.2/lib/net30/Spring.Core.pdb
  203. +49,291 −0 packages/Spring.Core.1.3.2/lib/net30/Spring.Core.xml
  204. BIN  packages/Spring.Core.1.3.2/lib/net35/Spring.Core.dll
  205. BIN  packages/Spring.Core.1.3.2/lib/net35/Spring.Core.pdb
  206. +49,291 −0 packages/Spring.Core.1.3.2/lib/net35/Spring.Core.xml
  207. BIN  packages/Spring.Core.1.3.2/lib/net40/Spring.Core.dll
  208. BIN  packages/Spring.Core.1.3.2/lib/net40/Spring.Core.pdb
  209. +49,291 −0 packages/Spring.Core.1.3.2/lib/net40/Spring.Core.xml
  210. BIN  packages/Spring.Data.1.3.2/Spring.Data.1.3.2.nupkg
  211. BIN  packages/Spring.Data.1.3.2/lib/net11/Spring.Data.dll
  212. BIN  packages/Spring.Data.1.3.2/lib/net11/Spring.Data.pdb
  213. +10,535 −0 packages/Spring.Data.1.3.2/lib/net11/Spring.Data.xml
  214. BIN  packages/Spring.Data.1.3.2/lib/net20/Spring.Data.dll
  215. BIN  packages/Spring.Data.1.3.2/lib/net20/Spring.Data.pdb
  216. +11,693 −0 packages/Spring.Data.1.3.2/lib/net20/Spring.Data.xml
  217. BIN  packages/Spring.Data.1.3.2/lib/net30/Spring.Data.dll
  218. BIN  packages/Spring.Data.1.3.2/lib/net30/Spring.Data.pdb
  219. +11,693 −0 packages/Spring.Data.1.3.2/lib/net30/Spring.Data.xml
  220. BIN  packages/Spring.Data.1.3.2/lib/net35/Spring.Data.dll
  221. BIN  packages/Spring.Data.1.3.2/lib/net35/Spring.Data.pdb
  222. +11,693 −0 packages/Spring.Data.1.3.2/lib/net35/Spring.Data.xml
  223. BIN  packages/Spring.Data.1.3.2/lib/net40/Spring.Data.dll
  224. BIN  packages/Spring.Data.1.3.2/lib/net40/Spring.Data.pdb
  225. +11,693 −0 packages/Spring.Data.1.3.2/lib/net40/Spring.Data.xml
  226. BIN  packages/Spring.Messaging.Amqp.1.0/Spring.Messaging.Amqp.1.0.nupkg
  227. BIN  packages/Spring.Messaging.Amqp.1.0/lib/net40/Spring.Messaging.Amqp.dll
  228. BIN  packages/Spring.Messaging.Amqp.Rabbit.1.0/Spring.Messaging.Amqp.Rabbit.1.0.nupkg
  229. BIN  packages/Spring.Messaging.Amqp.Rabbit.1.0/lib/net40/Spring.Messaging.Amqp.Rabbit.dll
  230. BIN  packages/Spring.Messaging.Amqp.Rabbit.Admin.1.0/lib/net40/Spring.Messaging.Amqp.Rabbit.Admin.dll
  231. BIN  packages/Spring.Messaging.Erlang.1.0/lib/net40/Spring.Erlang.dll
  232. BIN  packages/Spring.Threading.1.0/lib/Spring.Threading.dll
  233. +7 −0 packages/Spring.Threading.1.0/lib/Spring.Threading.dll.VisualState.xml
  234. BIN  packages/Spring.Threading.dll
  235. BIN  packages/Unity.2.1.505.0/Unity.2.1.505.0.nupkg
  236. BIN  packages/Unity.2.1.505.0/lib/NET35/Microsoft.Practices.Unity.Configuration.dll
  237. +2,451 −0 packages/Unity.2.1.505.0/lib/NET35/Microsoft.Practices.Unity.Configuration.xml
  238. BIN  packages/Unity.2.1.505.0/lib/NET35/Microsoft.Practices.Unity.dll
  239. +5,910 −0 packages/Unity.2.1.505.0/lib/NET35/Microsoft.Practices.Unity.xml
  240. BIN  packages/Unity.2.1.505.0/lib/SL30/Microsoft.Practices.Unity.Silverlight.dll
  241. +5,928 −0 packages/Unity.2.1.505.0/lib/SL30/Microsoft.Practices.Unity.Silverlight.xml
  242. BIN  packages/Unity.2.1.505.0/tools/Utils.psm1
  243. BIN  packages/Unity.2.1.505.0/tools/install.ps1
  244. BIN  packages/log4net.1.2.10/lib/1.0/log4net.dll
  245. +28,655 −0 packages/log4net.1.2.10/lib/1.0/log4net.xml
  246. BIN  packages/log4net.1.2.10/lib/1.1/log4net.dll
  247. +28,655 −0 packages/log4net.1.2.10/lib/1.1/log4net.xml
  248. BIN  packages/log4net.1.2.10/lib/2.0/log4net.dll
  249. +28,655 −0 packages/log4net.1.2.10/lib/2.0/log4net.xml
  250. BIN  packages/log4net.1.2.10/log4net.1.2.10.nupkg
  251. +83 −0 spring-net-amqp-samples.sln
View
21 Spring.Amqp.HelloWorld/Spring.Amqp.HelloWorld.BrokerConfiguration/Program.cs
@@ -1,4 +1,23 @@
-#region
+#region License
+
+/*
+ * Copyright 2002-2010 the original author or authors.
+ *
+ * Licensed 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.
+ */
+
+#endregion
+#region
using System;
using Spring.Messaging.Amqp.Core;
View
43 ...mqp.HelloWorld.BrokerConfiguration/Spring.Amqp.HelloWorld.BrokerConfiguration.2010.csproj
@@ -54,13 +54,32 @@
</PropertyGroup>
<ItemGroup>
<Reference Include="Common.Logging">
- <HintPath>..\..\..\packages\Common.Logging.2.0.0\lib\2.0\Common.Logging.dll</HintPath>
+ <HintPath>..\..\packages\Common.Logging.2.0.0\lib\2.0\Common.Logging.dll</HintPath>
</Reference>
<Reference Include="RabbitMQ.Client">
- <HintPath>..\..\..\packages\RabbitMQ.Client.2.5.1\lib\net30\RabbitMQ.Client.dll</HintPath>
+ <HintPath>..\..\packages\RabbitMQ.Client.2.5.1\lib\net30\RabbitMQ.Client.dll</HintPath>
+ </Reference>
+ <Reference Include="Spring.Aop">
+ <HintPath>..\..\packages\Spring.Aop.1.3.2\lib\net40\Spring.Aop.dll</HintPath>
</Reference>
<Reference Include="Spring.Core">
- <HintPath>..\..\..\packages\Spring.Core.1.3.2\lib\net40\Spring.Core.dll</HintPath>
+ <HintPath>..\..\packages\Spring.Core.1.3.2\lib\net40\Spring.Core.dll</HintPath>
+ </Reference>
+ <Reference Include="Spring.Data">
+ <HintPath>..\..\packages\Spring.Data.1.3.2\lib\net40\Spring.Data.dll</HintPath>
+ </Reference>
+ <Reference Include="Spring.Erlang, Version=1.0.0.0, Culture=neutral, processorArchitecture=MSIL">
+ <SpecificVersion>False</SpecificVersion>
+ <HintPath>..\..\packages\Spring.Messaging.Erlang.1.0\lib\net40\Spring.Erlang.dll</HintPath>
+ </Reference>
+ <Reference Include="Spring.Messaging.Amqp">
+ <HintPath>..\..\packages\Spring.Messaging.Amqp.1.0\lib\net40\Spring.Messaging.Amqp.dll</HintPath>
+ </Reference>
+ <Reference Include="Spring.Messaging.Amqp.Rabbit">
+ <HintPath>..\..\packages\Spring.Messaging.Amqp.Rabbit.1.0\lib\net40\Spring.Messaging.Amqp.Rabbit.dll</HintPath>
+ </Reference>
+ <Reference Include="Spring.Messaging.Amqp.Rabbit.Admin">
+ <HintPath>..\..\packages\Spring.Messaging.Amqp.Rabbit.Admin.1.0\lib\net40\Spring.Messaging.Amqp.Rabbit.Admin.dll</HintPath>
</Reference>
<Reference Include="System" />
<Reference Include="System.Data" />
@@ -91,24 +110,6 @@
<None Include="app.config" />
<None Include="packages.config" />
</ItemGroup>
- <ItemGroup>
- <ProjectReference Include="..\..\..\src\Spring.Erlang\Spring.Erlang.2010.csproj">
- <Project>{2619BBAC-1C37-4AE7-923F-E40EB7805132}</Project>
- <Name>Spring.Erlang.2010</Name>
- </ProjectReference>
- <ProjectReference Include="..\..\..\src\Spring.Messaging.Amqp.Rabbit.Admin\Spring.Messaging.Amqp.Rabbit.Admin.2010.csproj">
- <Project>{EBC1D070-FC8A-4EAD-B2A7-3AC25AB62507}</Project>
- <Name>Spring.Messaging.Amqp.Rabbit.Admin.2010</Name>
- </ProjectReference>
- <ProjectReference Include="..\..\..\src\Spring.Messaging.Amqp.Rabbit\Spring.Messaging.Amqp.Rabbit.2010.csproj">
- <Project>{1B1394DA-24D3-47FE-84CA-7E33B077F686}</Project>
- <Name>Spring.Messaging.Amqp.Rabbit.2010</Name>
- </ProjectReference>
- <ProjectReference Include="..\..\..\src\Spring.Messaging.Amqp\Spring.Messaging.Amqp.2010.csproj">
- <Project>{96CD9010-9DDF-4D13-892A-5D60F01F3C90}</Project>
- <Name>Spring.Messaging.Amqp.2010</Name>
- </ProjectReference>
- </ItemGroup>
<Import Project="$(MSBuildToolsPath)\Microsoft.CSharp.targets" />
<!-- To modify your build process, add your task inside one of the targets below and uncomment it.
Other similar extension points exist, see Microsoft.Common.targets.
View
17 ...World.BrokerConfiguration/bin/Debug/Spring.Amqp.HelloWorld.BrokerConfiguration.exe.config
@@ -0,0 +1,17 @@
+<?xml version="1.0" encoding="utf-8"?>
+<configuration>
+ <startup>
+ <supportedRuntime version="v4.0" sku=".NETFramework,Version=v4.0" />
+ </startup>
+ <runtime>
+ <assemblyBinding xmlns="urn:schemas-microsoft-com:asm.v1">
+ <dependentAssembly>
+ <assemblyIdentity name="Common.Logging"
+ publicKeyToken="AF08829B84F0328E" />
+ <bindingRedirect oldVersion="1.2.0.0"
+ newVersion="2.0.0.0"/>
+ </dependentAssembly>
+ </assemblyBinding>
+
+ </runtime>
+</configuration>
View
BIN  ...World.BrokerConfiguration/bin/Debug/Spring.Amqp.HelloWorld.BrokerConfiguration.vshost.exe
Binary file not shown
View
17 ...rokerConfiguration/bin/Debug/Spring.Amqp.HelloWorld.BrokerConfiguration.vshost.exe.config
@@ -0,0 +1,17 @@
+<?xml version="1.0" encoding="utf-8"?>
+<configuration>
+ <startup>
+ <supportedRuntime version="v4.0" sku=".NETFramework,Version=v4.0" />
+ </startup>
+ <runtime>
+ <assemblyBinding xmlns="urn:schemas-microsoft-com:asm.v1">
+ <dependentAssembly>
+ <assemblyIdentity name="Common.Logging"
+ publicKeyToken="AF08829B84F0328E" />
+ <bindingRedirect oldVersion="1.2.0.0"
+ newVersion="2.0.0.0"/>
+ </dependentAssembly>
+ </assemblyBinding>
+
+ </runtime>
+</configuration>
View
11 ...kerConfiguration/bin/Debug/Spring.Amqp.HelloWorld.BrokerConfiguration.vshost.exe.manifest
@@ -0,0 +1,11 @@
+<?xml version="1.0" encoding="UTF-8" standalone="yes"?>
+<assembly xmlns="urn:schemas-microsoft-com:asm.v1" manifestVersion="1.0">
+ <assemblyIdentity version="1.0.0.0" name="MyApplication.app"/>
+ <trustInfo xmlns="urn:schemas-microsoft-com:asm.v2">
+ <security>
+ <requestedPrivileges xmlns="urn:schemas-microsoft-com:asm.v3">
+ <requestedExecutionLevel level="asInvoker" uiAccess="false"/>
+ </requestedPrivileges>
+ </security>
+ </trustInfo>
+</assembly>
View
BIN  ...p.HelloWorld.BrokerConfiguration/obj/Debug/DesignTimeResolveAssemblyReferencesInput.cache
Binary file not shown
View
1  ...ion/obj/Debug/Spring.Amqp.HelloWorld.BrokerConfiguration.2010.csproj.FileListAbsolute.txt
@@ -0,0 +1 @@
+C:\spring-net-amqp-samples\Spring.Amqp.HelloWorld\Spring.Amqp.HelloWorld.BrokerConfiguration\bin\Debug\Spring.Amqp.HelloWorld.BrokerConfiguration.exe.config
View
0  ...Amqp.HelloWorld.Consumer.Async/App.config → ...Amqp.HelloWorld.Consumer.Async/App.config
File renamed without changes
View
0  ...rld.Consumer.Async/Config/Application.xml → ...rld.Consumer.Async/Config/Application.xml
File renamed without changes
View
0  ...World.Consumer.Async/HelloWorldHandler.cs → ...World.Consumer.Async/HelloWorldHandler.cs
File renamed without changes
View
21 ...Amqp.HelloWorld.Consumer.Async/Program.cs → ...Amqp.HelloWorld.Consumer.Async/Program.cs
@@ -1,4 +1,23 @@
-using System;
+#region License
+
+/*
+ * Copyright 2002-2010 the original author or authors.
+ *
+ * Licensed 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.
+ */
+
+#endregion
+using System;
using System.Collections.Generic;
using System.Text;
using Common.Logging;
View
0  ...Consumer.Async/Properties/AssemblyInfo.cs → ...Consumer.Async/Properties/AssemblyInfo.cs
File renamed without changes
View
31 ...mqp.HelloWorld.Consumer.Async.2010.csproj → ...mqp.HelloWorld.Consumer.Async.2010.csproj
@@ -55,13 +55,28 @@
<ItemGroup>
<Reference Include="Common.Logging, Version=2.0.0.0, Culture=neutral, PublicKeyToken=af08829b84f0328e, processorArchitecture=MSIL">
<SpecificVersion>False</SpecificVersion>
- <HintPath>..\..\..\..\packages\Common.Logging.2.0.0\lib\2.0\Common.Logging.dll</HintPath>
+ <HintPath>..\..\packages\Common.Logging.2.0.0\lib\2.0\Common.Logging.dll</HintPath>
</Reference>
<Reference Include="RabbitMQ.Client">
- <HintPath>..\..\..\..\packages\RabbitMQ.Client.2.5.1\lib\net30\RabbitMQ.Client.dll</HintPath>
+ <HintPath>..\..\packages\RabbitMQ.Client.2.5.1\lib\net30\RabbitMQ.Client.dll</HintPath>
+ </Reference>
+ <Reference Include="Spring.Aop">
+ <HintPath>..\..\packages\Spring.Aop.1.3.2\lib\net40\Spring.Aop.dll</HintPath>
</Reference>
<Reference Include="Spring.Core">
- <HintPath>..\..\..\..\packages\Spring.Core.1.3.2\lib\net40\Spring.Core.dll</HintPath>
+ <HintPath>..\..\packages\Spring.Core.1.3.2\lib\net40\Spring.Core.dll</HintPath>
+ </Reference>
+ <Reference Include="Spring.Data">
+ <HintPath>..\..\packages\Spring.Data.1.3.2\lib\net40\Spring.Data.dll</HintPath>
+ </Reference>
+ <Reference Include="Spring.Messaging.Amqp">
+ <HintPath>..\..\packages\Spring.Messaging.Amqp.1.0\lib\net40\Spring.Messaging.Amqp.dll</HintPath>
+ </Reference>
+ <Reference Include="Spring.Messaging.Amqp.Rabbit">
+ <HintPath>..\..\packages\Spring.Messaging.Amqp.Rabbit.1.0\lib\net40\Spring.Messaging.Amqp.Rabbit.dll</HintPath>
+ </Reference>
+ <Reference Include="Spring.Threading">
+ <HintPath>..\..\packages\Spring.Threading.1.0\lib\Spring.Threading.dll</HintPath>
</Reference>
<Reference Include="System" />
<Reference Include="System.Data" />
@@ -98,16 +113,6 @@
<Install>true</Install>
</BootstrapperPackage>
</ItemGroup>
- <ItemGroup>
- <ProjectReference Include="..\..\..\..\src\Spring.Messaging.Amqp.Rabbit\Spring.Messaging.Amqp.Rabbit.2010.csproj">
- <Project>{1B1394DA-24D3-47FE-84CA-7E33B077F686}</Project>
- <Name>Spring.Messaging.Amqp.Rabbit.2010</Name>
- </ProjectReference>
- <ProjectReference Include="..\..\..\..\src\Spring.Messaging.Amqp\Spring.Messaging.Amqp.2010.csproj">
- <Project>{96CD9010-9DDF-4D13-892A-5D60F01F3C90}</Project>
- <Name>Spring.Messaging.Amqp.2010</Name>
- </ProjectReference>
- </ItemGroup>
<Import Project="$(MSBuildToolsPath)\Microsoft.CSharp.targets" />
<!-- To modify your build process, add your task inside one of the targets below and uncomment it.
Other similar extension points exist, see Microsoft.Common.targets.
View
BIN  ...Amqp.HelloWorld.Consumer.Async/bin/Debug/Spring.Amqp.HelloWorld.Consumer.Async.vshost.exe
Binary file not shown
View
50 ...lloWorld.Consumer.Async/bin/Debug/Spring.Amqp.HelloWorld.Consumer.Async.vshost.exe.config
@@ -0,0 +1,50 @@
+<?xml version="1.0" encoding="utf-8"?>
+<configuration>
+ <configSections>
+ <sectionGroup name="spring">
+ <section name="context" type="Spring.Context.Support.ContextHandler, Spring.Core" />
+ </sectionGroup>
+ <sectionGroup name="common">
+ <section name="logging" type="Common.Logging.ConfigurationSectionHandler, Common.Logging" />
+ </sectionGroup>
+ </configSections>
+ <spring>
+ <context>
+ <resource uri="~/Config/Application.xml" />
+ </context>
+ </spring>
+ <common>
+ <logging>
+ <factoryAdapter type="Common.Logging.Simple.ConsoleOutLoggerFactoryAdapter, Common.Logging">
+ <arg key="showLogName" value="true" />
+ <arg key="showDataTime" value="true" />
+ <arg key="level" value="INFO" />
+ <arg key="dateTimeFormat" value="yyyy/MM/dd HH:mm:ss:fff" />
+ </factoryAdapter>
+ </logging>
+ </common>
+ <startup>
+ <supportedRuntime version="v4.0" sku=".NETFramework,Version=v4.0" />
+ </startup>
+ <runtime>
+ <assemblyBinding xmlns="urn:schemas-microsoft-com:asm.v1">
+ <dependentAssembly>
+ <assemblyIdentity name="Spring.Aop" publicKeyToken="65e474d141e25e07" culture="neutral" />
+ <bindingRedirect oldVersion="0.0.0.0-1.3.1.40711" newVersion="1.3.1.40711" />
+ </dependentAssembly>
+ <dependentAssembly>
+ <assemblyIdentity name="Spring.Core" publicKeyToken="65e474d141e25e07" culture="neutral" />
+ <bindingRedirect oldVersion="0.0.0.0-1.3.1.40711" newVersion="1.3.1.40711" />
+ </dependentAssembly>
+ </assemblyBinding>
+
+ <assemblyBinding xmlns="urn:schemas-microsoft-com:asm.v1">
+ <dependentAssembly>
+ <assemblyIdentity name="Common.Logging"
+ publicKeyToken="AF08829B84F0328E" />
+ <bindingRedirect oldVersion="1.2.0.0"
+ newVersion="2.0.0.0"/>
+ </dependentAssembly>
+ </assemblyBinding>
+ </runtime>
+</configuration>
View
11 ...oWorld.Consumer.Async/bin/Debug/Spring.Amqp.HelloWorld.Consumer.Async.vshost.exe.manifest
@@ -0,0 +1,11 @@
+<?xml version="1.0" encoding="UTF-8" standalone="yes"?>
+<assembly xmlns="urn:schemas-microsoft-com:asm.v1" manifestVersion="1.0">
+ <assemblyIdentity version="1.0.0.0" name="MyApplication.app"/>
+ <trustInfo xmlns="urn:schemas-microsoft-com:asm.v2">
+ <security>
+ <requestedPrivileges xmlns="urn:schemas-microsoft-com:asm.v3">
+ <requestedExecutionLevel level="asInvoker" uiAccess="false"/>
+ </requestedPrivileges>
+ </security>
+ </trustInfo>
+</assembly>
View
BIN  ...g.Amqp.HelloWorld.Consumer.Async/obj/Debug/DesignTimeResolveAssemblyReferencesInput.cache
Binary file not shown
View
0  ...HelloWorld.Consumer.Async/packages.config → ...HelloWorld.Consumer.Async/packages.config
File renamed without changes
View
28 ...qp.HelloWorld/Spring.Amqp.HelloWorld.Consumer/Spring.Amqp.HelloWorld.Consumer.2010.csproj
@@ -54,15 +54,27 @@
</PropertyGroup>
<ItemGroup>
<Reference Include="Common.Logging">
- <HintPath>..\..\..\packages\Common.Logging.2.0.0\lib\2.0\Common.Logging.dll</HintPath>
+ <HintPath>..\..\packages\Common.Logging.2.0.0\lib\2.0\Common.Logging.dll</HintPath>
</Reference>
<Reference Include="RabbitMQ.Client, Version=2.4.1.0, Culture=neutral, PublicKeyToken=89e7d7c5feba84ce, processorArchitecture=MSIL">
<SpecificVersion>False</SpecificVersion>
- <HintPath>..\..\..\packages\RabbitMQ.Client.2.5.1\lib\net30\RabbitMQ.Client.dll</HintPath>
+ <HintPath>..\..\packages\RabbitMQ.Client.2.5.1\lib\net30\RabbitMQ.Client.dll</HintPath>
+ </Reference>
+ <Reference Include="Spring.Aop">
+ <HintPath>..\..\packages\Spring.Aop.1.3.2\lib\net40\Spring.Aop.dll</HintPath>
</Reference>
<Reference Include="Spring.Core, Version=1.3.1.20711, Culture=neutral, PublicKeyToken=65e474d141e25e07, processorArchitecture=MSIL">
<SpecificVersion>False</SpecificVersion>
- <HintPath>..\..\..\packages\Spring.Core.1.3.2\lib\net40\Spring.Core.dll</HintPath>
+ <HintPath>..\..\packages\Spring.Core.1.3.2\lib\net40\Spring.Core.dll</HintPath>
+ </Reference>
+ <Reference Include="Spring.Data">
+ <HintPath>..\..\packages\Spring.Data.1.3.2\lib\net40\Spring.Data.dll</HintPath>
+ </Reference>
+ <Reference Include="Spring.Messaging.Amqp">
+ <HintPath>..\..\packages\Spring.Messaging.Amqp.1.0\lib\net40\Spring.Messaging.Amqp.dll</HintPath>
+ </Reference>
+ <Reference Include="Spring.Messaging.Amqp.Rabbit">
+ <HintPath>..\..\packages\Spring.Messaging.Amqp.Rabbit.1.0\lib\net40\Spring.Messaging.Amqp.Rabbit.dll</HintPath>
</Reference>
<Reference Include="System" />
<Reference Include="System.Data" />
@@ -98,16 +110,6 @@
<Install>true</Install>
</BootstrapperPackage>
</ItemGroup>
- <ItemGroup>
- <ProjectReference Include="..\..\..\src\Spring.Messaging.Amqp.Rabbit\Spring.Messaging.Amqp.Rabbit.2010.csproj">
- <Project>{1B1394DA-24D3-47FE-84CA-7E33B077F686}</Project>
- <Name>Spring.Messaging.Amqp.Rabbit.2010</Name>
- </ProjectReference>
- <ProjectReference Include="..\..\..\src\Spring.Messaging.Amqp\Spring.Messaging.Amqp.2010.csproj">
- <Project>{96CD9010-9DDF-4D13-892A-5D60F01F3C90}</Project>
- <Name>Spring.Messaging.Amqp.2010</Name>
- </ProjectReference>
- </ItemGroup>
<Import Project="$(MSBuildToolsPath)\Microsoft.CSharp.targets" />
<!-- To modify your build process, add your task inside one of the targets below and uncomment it.
Other similar extension points exist, see Microsoft.Common.targets.
View
BIN  ...orld/Spring.Amqp.HelloWorld.Consumer/bin/Debug/Spring.Amqp.HelloWorld.Consumer.vshost.exe
Binary file not shown
View
51 ...ring.Amqp.HelloWorld.Consumer/bin/Debug/Spring.Amqp.HelloWorld.Consumer.vshost.exe.config
@@ -0,0 +1,51 @@
+<?xml version="1.0" encoding="utf-8"?>
+<configuration>
+ <configSections>
+ <sectionGroup name="spring">
+ <section name="context" type="Spring.Context.Support.ContextHandler, Spring.Core" />
+ </sectionGroup>
+ <sectionGroup name="common">
+ <section name="logging" type="Common.Logging.ConfigurationSectionHandler, Common.Logging" />
+ </sectionGroup>
+ </configSections>
+ <spring>
+ <context>
+ <resource uri="~/Config/Application.xml" />
+ </context>
+ </spring>
+ <common>
+ <logging>
+ <factoryAdapter type="Common.Logging.Simple.ConsoleOutLoggerFactoryAdapter, Common.Logging">
+ <arg key="showLogName" value="true" />
+ <arg key="showDataTime" value="true" />
+ <arg key="level" value="INFO" />
+ <arg key="dateTimeFormat" value="yyyy/MM/dd HH:mm:ss:fff" />
+ </factoryAdapter>
+ </logging>
+ </common>
+ <startup>
+ <supportedRuntime version="v4.0" sku=".NETFramework,Version=v4.0" />
+ </startup>
+ <runtime>
+ <assemblyBinding xmlns="urn:schemas-microsoft-com:asm.v1">
+ <dependentAssembly>
+ <assemblyIdentity name="Spring.Aop" publicKeyToken="65e474d141e25e07" culture="neutral" />
+ <bindingRedirect oldVersion="0.0.0.0-1.3.1.40711" newVersion="1.3.1.40711" />
+ </dependentAssembly>
+ <dependentAssembly>
+ <assemblyIdentity name="Spring.Core" publicKeyToken="65e474d141e25e07" culture="neutral" />
+ <bindingRedirect oldVersion="0.0.0.0-1.3.1.40711" newVersion="1.3.1.40711" />
+ </dependentAssembly>
+ </assemblyBinding>
+
+ <assemblyBinding xmlns="urn:schemas-microsoft-com:asm.v1">
+ <dependentAssembly>
+ <assemblyIdentity name="Common.Logging"
+ publicKeyToken="AF08829B84F0328E" />
+ <bindingRedirect oldVersion="1.2.0.0"
+ newVersion="2.0.0.0"/>
+ </dependentAssembly>
+ </assemblyBinding>
+
+ </runtime>
+</configuration>
View
11 ...ng.Amqp.HelloWorld.Consumer/bin/Debug/Spring.Amqp.HelloWorld.Consumer.vshost.exe.manifest
@@ -0,0 +1,11 @@
+<?xml version="1.0" encoding="UTF-8" standalone="yes"?>
+<assembly xmlns="urn:schemas-microsoft-com:asm.v1" manifestVersion="1.0">
+ <assemblyIdentity version="1.0.0.0" name="MyApplication.app"/>
+ <trustInfo xmlns="urn:schemas-microsoft-com:asm.v2">
+ <security>
+ <requestedPrivileges xmlns="urn:schemas-microsoft-com:asm.v3">
+ <requestedExecutionLevel level="asInvoker" uiAccess="false"/>
+ </requestedPrivileges>
+ </security>
+ </trustInfo>
+</assembly>
View
BIN  .../Spring.Amqp.HelloWorld.Consumer/obj/Debug/DesignTimeResolveAssemblyReferencesInput.cache
Binary file not shown
View
21 Spring.Amqp.HelloWorld/Spring.Amqp.HelloWorld.Producer.Async/Program.cs
@@ -1,4 +1,23 @@
-using System;
+#region License
+
+/*
+ * Copyright 2002-2010 the original author or authors.
+ *
+ * Licensed 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.
+ */
+
+#endregion
+using System;
using System.Collections.Generic;
using System.Text;
using System.Threading;
View
27 ...d/Spring.Amqp.HelloWorld.Producer.Async/Spring.Amqp.HelloWorld.Producer.Async.2010.csproj
@@ -54,19 +54,28 @@
</PropertyGroup>
<ItemGroup>
<Reference Include="Common.Logging">
- <HintPath>..\..\..\packages\Common.Logging.2.0.0\lib\2.0\Common.Logging.dll</HintPath>
+ <HintPath>..\..\packages\Common.Logging.2.0.0\lib\2.0\Common.Logging.dll</HintPath>
</Reference>
<Reference Include="RabbitMQ.Client, Version=2.4.1.0, Culture=neutral, PublicKeyToken=89e7d7c5feba84ce, processorArchitecture=MSIL">
<SpecificVersion>False</SpecificVersion>
- <HintPath>..\..\..\packages\RabbitMQ.Client.2.5.1\lib\net30\RabbitMQ.Client.dll</HintPath>
+ <HintPath>..\..\packages\RabbitMQ.Client.2.5.1\lib\net30\RabbitMQ.Client.dll</HintPath>
</Reference>
<Reference Include="Spring.Aop, Version=1.3.1.20711, Culture=neutral, PublicKeyToken=65e474d141e25e07, processorArchitecture=MSIL">
<SpecificVersion>False</SpecificVersion>
- <HintPath>..\..\..\packages\Spring.Aop.1.3.2\lib\net40\Spring.Aop.dll</HintPath>
+ <HintPath>..\..\packages\Spring.Aop.1.3.2\lib\net40\Spring.Aop.dll</HintPath>
</Reference>
<Reference Include="Spring.Core, Version=1.3.1.20711, Culture=neutral, PublicKeyToken=65e474d141e25e07, processorArchitecture=MSIL">
<SpecificVersion>False</SpecificVersion>
- <HintPath>..\..\..\packages\Spring.Core.1.3.2\lib\net40\Spring.Core.dll</HintPath>
+ <HintPath>..\..\packages\Spring.Core.1.3.2\lib\net40\Spring.Core.dll</HintPath>
+ </Reference>
+ <Reference Include="Spring.Data">
+ <HintPath>..\..\packages\Spring.Data.1.3.2\lib\net40\Spring.Data.dll</HintPath>
+ </Reference>
+ <Reference Include="Spring.Messaging.Amqp">
+ <HintPath>..\..\packages\Spring.Messaging.Amqp.1.0\lib\net40\Spring.Messaging.Amqp.dll</HintPath>
+ </Reference>
+ <Reference Include="Spring.Messaging.Amqp.Rabbit">
+ <HintPath>..\..\packages\Spring.Messaging.Amqp.Rabbit.1.0\lib\net40\Spring.Messaging.Amqp.Rabbit.dll</HintPath>
</Reference>
<Reference Include="System" />
<Reference Include="System.Data" />
@@ -102,16 +111,6 @@
<Install>true</Install>
</BootstrapperPackage>
</ItemGroup>
- <ItemGroup>
- <ProjectReference Include="..\..\..\src\Spring.Messaging.Amqp.Rabbit\Spring.Messaging.Amqp.Rabbit.2010.csproj">
- <Project>{1B1394DA-24D3-47FE-84CA-7E33B077F686}</Project>
- <Name>Spring.Messaging.Amqp.Rabbit.2010</Name>
- </ProjectReference>
- <ProjectReference Include="..\..\..\src\Spring.Messaging.Amqp\Spring.Messaging.Amqp.2010.csproj">
- <Project>{96CD9010-9DDF-4D13-892A-5D60F01F3C90}</Project>
- <Name>Spring.Messaging.Amqp.2010</Name>
- </ProjectReference>
- </ItemGroup>
<Import Project="$(MSBuildToolsPath)\Microsoft.CSharp.targets" />
<!-- To modify your build process, add your task inside one of the targets below and uncomment it.
Other similar extension points exist, see Microsoft.Common.targets.
View
BIN  ...Amqp.HelloWorld.Producer.Async/bin/Debug/Spring.Amqp.HelloWorld.Producer.Async.vshost.exe
Binary file not shown
View
51 ...lloWorld.Producer.Async/bin/Debug/Spring.Amqp.HelloWorld.Producer.Async.vshost.exe.config
@@ -0,0 +1,51 @@
+<?xml version="1.0" encoding="utf-8"?>
+<configuration>
+ <configSections>
+ <sectionGroup name="spring">
+ <section name="context" type="Spring.Context.Support.ContextHandler, Spring.Core" />
+ </sectionGroup>
+ <sectionGroup name="common">
+ <section name="logging" type="Common.Logging.ConfigurationSectionHandler, Common.Logging" />
+ </sectionGroup>
+ </configSections>
+ <spring>
+ <context>
+ <resource uri="~/Config/Application.xml" />
+ </context>
+ </spring>
+ <common>
+ <logging>
+ <factoryAdapter type="Common.Logging.Simple.ConsoleOutLoggerFactoryAdapter, Common.Logging">
+ <arg key="showLogName" value="true" />
+ <arg key="showDataTime" value="true" />
+ <arg key="level" value="INFO" />
+ <arg key="dateTimeFormat" value="yyyy/MM/dd HH:mm:ss:fff" />
+ </factoryAdapter>
+ </logging>
+ </common>
+ <startup>
+ <supportedRuntime version="v4.0" sku=".NETFramework,Version=v4.0" />
+ </startup>
+ <runtime>
+ <assemblyBinding xmlns="urn:schemas-microsoft-com:asm.v1">
+ <dependentAssembly>
+ <assemblyIdentity name="Spring.Aop" publicKeyToken="65e474d141e25e07" culture="neutral" />
+ <bindingRedirect oldVersion="0.0.0.0-1.3.1.40711" newVersion="1.3.1.40711" />
+ </dependentAssembly>
+ <dependentAssembly>
+ <assemblyIdentity name="Spring.Core" publicKeyToken="65e474d141e25e07" culture="neutral" />
+ <bindingRedirect oldVersion="0.0.0.0-1.3.1.40711" newVersion="1.3.1.40711" />
+ </dependentAssembly>
+ </assemblyBinding>
+
+ <assemblyBinding xmlns="urn:schemas-microsoft-com:asm.v1">
+ <dependentAssembly>
+ <assemblyIdentity name="Common.Logging"
+ publicKeyToken="AF08829B84F0328E" />
+ <bindingRedirect oldVersion="1.2.0.0"
+ newVersion="2.0.0.0"/>
+ </dependentAssembly>
+ </assemblyBinding>
+
+ </runtime>
+</configuration>
View
11 ...oWorld.Producer.Async/bin/Debug/Spring.Amqp.HelloWorld.Producer.Async.vshost.exe.manifest
@@ -0,0 +1,11 @@
+<?xml version="1.0" encoding="UTF-8" standalone="yes"?>
+<assembly xmlns="urn:schemas-microsoft-com:asm.v1" manifestVersion="1.0">
+ <assemblyIdentity version="1.0.0.0" name="MyApplication.app"/>
+ <trustInfo xmlns="urn:schemas-microsoft-com:asm.v2">
+ <security>
+ <requestedPrivileges xmlns="urn:schemas-microsoft-com:asm.v3">
+ <requestedExecutionLevel level="asInvoker" uiAccess="false"/>
+ </requestedPrivileges>
+ </security>
+ </trustInfo>
+</assembly>
View
BIN  ...g.Amqp.HelloWorld.Producer.Async/obj/Debug/DesignTimeResolveAssemblyReferencesInput.cache
Binary file not shown
View
28 ...qp.HelloWorld/Spring.Amqp.HelloWorld.Producer/Spring.Amqp.HelloWorld.Producer.2010.csproj
@@ -54,15 +54,27 @@
</PropertyGroup>
<ItemGroup>
<Reference Include="Common.Logging">
- <HintPath>..\..\..\packages\Common.Logging.2.0.0\lib\2.0\Common.Logging.dll</HintPath>
+ <HintPath>..\..\packages\Common.Logging.2.0.0\lib\2.0\Common.Logging.dll</HintPath>
</Reference>
<Reference Include="RabbitMQ.Client, Version=2.4.1.0, Culture=neutral, PublicKeyToken=89e7d7c5feba84ce, processorArchitecture=MSIL">
<SpecificVersion>False</SpecificVersion>
- <HintPath>..\..\..\packages\RabbitMQ.Client.2.5.1\lib\net30\RabbitMQ.Client.dll</HintPath>
+ <HintPath>..\..\packages\RabbitMQ.Client.2.5.1\lib\net30\RabbitMQ.Client.dll</HintPath>
+ </Reference>
+ <Reference Include="Spring.Aop">
+ <HintPath>..\..\packages\Spring.Aop.1.3.2\lib\net40\Spring.Aop.dll</HintPath>
</Reference>
<Reference Include="Spring.Core, Version=1.3.1.20711, Culture=neutral, PublicKeyToken=65e474d141e25e07, processorArchitecture=MSIL">
<SpecificVersion>False</SpecificVersion>
- <HintPath>..\..\..\packages\Spring.Core.1.3.2\lib\net40\Spring.Core.dll</HintPath>
+ <HintPath>..\..\packages\Spring.Core.1.3.2\lib\net40\Spring.Core.dll</HintPath>
+ </Reference>
+ <Reference Include="Spring.Data">
+ <HintPath>..\..\packages\Spring.Data.1.3.2\lib\net40\Spring.Data.dll</HintPath>
+ </Reference>
+ <Reference Include="Spring.Messaging.Amqp">
+ <HintPath>..\..\packages\Spring.Messaging.Amqp.1.0\lib\net40\Spring.Messaging.Amqp.dll</HintPath>
+ </Reference>
+ <Reference Include="Spring.Messaging.Amqp.Rabbit">
+ <HintPath>..\..\packages\Spring.Messaging.Amqp.Rabbit.1.0\lib\net40\Spring.Messaging.Amqp.Rabbit.dll</HintPath>
</Reference>
<Reference Include="System" />
<Reference Include="System.Data" />
@@ -99,16 +111,6 @@
<Install>true</Install>
</BootstrapperPackage>
</ItemGroup>
- <ItemGroup>
- <ProjectReference Include="..\..\..\src\Spring.Messaging.Amqp.Rabbit\Spring.Messaging.Amqp.Rabbit.2010.csproj">
- <Project>{1B1394DA-24D3-47FE-84CA-7E33B077F686}</Project>
- <Name>Spring.Messaging.Amqp.Rabbit.2010</Name>
- </ProjectReference>
- <ProjectReference Include="..\..\..\src\Spring.Messaging.Amqp\Spring.Messaging.Amqp.2010.csproj">
- <Project>{96CD9010-9DDF-4D13-892A-5D60F01F3C90}</Project>
- <Name>Spring.Messaging.Amqp.2010</Name>
- </ProjectReference>
- </ItemGroup>
<Import Project="$(MSBuildToolsPath)\Microsoft.CSharp.targets" />
<!-- To modify your build process, add your task inside one of the targets below and uncomment it.
Other similar extension points exist, see Microsoft.Common.targets.
View
BIN  ...orld/Spring.Amqp.HelloWorld.Producer/bin/Debug/Spring.Amqp.HelloWorld.Producer.vshost.exe
Binary file not shown
View
51 ...ring.Amqp.HelloWorld.Producer/bin/Debug/Spring.Amqp.HelloWorld.Producer.vshost.exe.config
@@ -0,0 +1,51 @@
+<?xml version="1.0" encoding="utf-8"?>
+<configuration>
+ <configSections>
+ <sectionGroup name="spring">
+ <section name="context" type="Spring.Context.Support.ContextHandler, Spring.Core" />
+ </sectionGroup>
+ <sectionGroup name="common">
+ <section name="logging" type="Common.Logging.ConfigurationSectionHandler, Common.Logging" />
+ </sectionGroup>
+ </configSections>
+ <spring>
+ <context>
+ <resource uri="~/Config/Application.xml" />
+ </context>
+ </spring>
+ <common>
+ <logging>
+ <factoryAdapter type="Common.Logging.Simple.ConsoleOutLoggerFactoryAdapter, Common.Logging">
+ <arg key="showLogName" value="true" />
+ <arg key="showDataTime" value="true" />
+ <arg key="level" value="INFO" />
+ <arg key="dateTimeFormat" value="yyyy/MM/dd HH:mm:ss:fff" />
+ </factoryAdapter>
+ </logging>
+ </common>
+ <startup>
+ <supportedRuntime version="v4.0" sku=".NETFramework,Version=v4.0" />
+ </startup>
+ <runtime>
+ <assemblyBinding xmlns="urn:schemas-microsoft-com:asm.v1">
+ <dependentAssembly>
+ <assemblyIdentity name="Spring.Aop" publicKeyToken="65e474d141e25e07" culture="neutral" />
+ <bindingRedirect oldVersion="0.0.0.0-1.3.1.40711" newVersion="1.3.1.40711" />
+ </dependentAssembly>
+ <dependentAssembly>
+ <assemblyIdentity name="Spring.Core" publicKeyToken="65e474d141e25e07" culture="neutral" />
+ <bindingRedirect oldVersion="0.0.0.0-1.3.1.40711" newVersion="1.3.1.40711" />
+ </dependentAssembly>
+ </assemblyBinding>
+
+ <assemblyBinding xmlns="urn:schemas-microsoft-com:asm.v1">
+ <dependentAssembly>
+ <assemblyIdentity name="Common.Logging"
+ publicKeyToken="AF08829B84F0328E" />
+ <bindingRedirect oldVersion="1.2.0.0"
+ newVersion="2.0.0.0"/>
+ </dependentAssembly>
+ </assemblyBinding>
+
+ </runtime>
+</configuration>
View
11 ...ng.Amqp.HelloWorld.Producer/bin/Debug/Spring.Amqp.HelloWorld.Producer.vshost.exe.manifest
@@ -0,0 +1,11 @@
+<?xml version="1.0" encoding="UTF-8" standalone="yes"?>
+<assembly xmlns="urn:schemas-microsoft-com:asm.v1" manifestVersion="1.0">
+ <assemblyIdentity version="1.0.0.0" name="MyApplication.app"/>
+ <trustInfo xmlns="urn:schemas-microsoft-com:asm.v2">
+ <security>
+ <requestedPrivileges xmlns="urn:schemas-microsoft-com:asm.v3">
+ <requestedExecutionLevel level="asInvoker" uiAccess="false"/>
+ </requestedPrivileges>
+ </security>
+ </trustInfo>
+</assembly>
View
BIN  .../Spring.Amqp.HelloWorld.Producer/obj/Debug/DesignTimeResolveAssemblyReferencesInput.cache
Binary file not shown
View
44 Spring.RabbitQuickStart/Spring.RabbitQuickStart.2010.sln
@@ -1,44 +0,0 @@
-
-Microsoft Visual Studio Solution File, Format Version 10.00
-# Visual Studio 2008
-Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "Spring.RabbitQuickStart.Server", "src\Spring\Spring.RabbitQuickStart.Server\Spring.RabbitQuickStart.Server.2010.csproj", "{44CBEE25-B904-4222-8F42-6DBE90BC37F1}"
-EndProject
-Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "Spring.RabbitQuickStart.Client", "src\Spring\Spring.RabbitQuickStart.Client\Spring.RabbitQuickStart.Client.2010.csproj", "{E45BAB1E-7C84-446A-AA5C-2EC6D336960B}"
-EndProject
-Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "Spring.Messaging.Amqp.2008", "..\..\src\Spring.Messaging.Amqp\Spring.Messaging.Amqp.2008.2010.csproj", "{96CD9010-9DDF-4D13-892A-5D60F01F3C90}"
-EndProject
-Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "Spring.Messaging.Amqp.Rabbit.2008", "..\..\src\Spring.Messaging.Amqp.Rabbit\Spring.Messaging.Amqp.Rabbit.2008.2010.csproj", "{1B1394DA-24D3-47FE-84CA-7E33B077F686}"
-EndProject
-Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "Spring.RabbitQuickStart.Common", "src\Spring\Spring.RabbitQuickStart.Common\Spring.RabbitQuickStart.Common.2010.csproj", "{DE909872-61DE-48EC-BD1A-8DEE4D993F5B}"
-EndProject
-Global
- GlobalSection(SolutionConfigurationPlatforms) = preSolution
- Debug|Any CPU = Debug|Any CPU
- Release|Any CPU = Release|Any CPU
- EndGlobalSection
- GlobalSection(ProjectConfigurationPlatforms) = postSolution
- {44CBEE25-B904-4222-8F42-6DBE90BC37F1}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
- {44CBEE25-B904-4222-8F42-6DBE90BC37F1}.Debug|Any CPU.Build.0 = Debug|Any CPU
- {44CBEE25-B904-4222-8F42-6DBE90BC37F1}.Release|Any CPU.ActiveCfg = Release|Any CPU
- {44CBEE25-B904-4222-8F42-6DBE90BC37F1}.Release|Any CPU.Build.0 = Release|Any CPU
- {E45BAB1E-7C84-446A-AA5C-2EC6D336960B}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
- {E45BAB1E-7C84-446A-AA5C-2EC6D336960B}.Debug|Any CPU.Build.0 = Debug|Any CPU
- {E45BAB1E-7C84-446A-AA5C-2EC6D336960B}.Release|Any CPU.ActiveCfg = Release|Any CPU
- {E45BAB1E-7C84-446A-AA5C-2EC6D336960B}.Release|Any CPU.Build.0 = Release|Any CPU
- {96CD9010-9DDF-4D13-892A-5D60F01F3C90}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
- {96CD9010-9DDF-4D13-892A-5D60F01F3C90}.Debug|Any CPU.Build.0 = Debug|Any CPU
- {96CD9010-9DDF-4D13-892A-5D60F01F3C90}.Release|Any CPU.ActiveCfg = Release|Any CPU
- {96CD9010-9DDF-4D13-892A-5D60F01F3C90}.Release|Any CPU.Build.0 = Release|Any CPU
- {1B1394DA-24D3-47FE-84CA-7E33B077F686}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
- {1B1394DA-24D3-47FE-84CA-7E33B077F686}.Debug|Any CPU.Build.0 = Debug|Any CPU
- {1B1394DA-24D3-47FE-84CA-7E33B077F686}.Release|Any CPU.ActiveCfg = Release|Any CPU
- {1B1394DA-24D3-47FE-84CA-7E33B077F686}.Release|Any CPU.Build.0 = Release|Any CPU
- {DE909872-61DE-48EC-BD1A-8DEE4D993F5B}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
- {DE909872-61DE-48EC-BD1A-8DEE4D993F5B}.Debug|Any CPU.Build.0 = Debug|Any CPU
- {DE909872-61DE-48EC-BD1A-8DEE4D993F5B}.Release|Any CPU.ActiveCfg = Release|Any CPU
- {DE909872-61DE-48EC-BD1A-8DEE4D993F5B}.Release|Any CPU.Build.0 = Release|Any CPU
- EndGlobalSection
- GlobalSection(SolutionProperties) = preSolution
- HideSolutionNode = FALSE
- EndGlobalSection
-EndGlobal
View
41 Spring.RabbitQuickStart/src/Spring/Spring.RabbitQuickStart.BrokerConfiguration/Program.cs
@@ -1,11 +1,36 @@
-
+#region License
+
+/*
+ * Copyright 2002-2010 the original author or authors.
+ *
+ * Licensed 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.
+ */
+
+#endregion
+
using System;
+using System.Configuration;
using Spring.Messaging.Amqp.Core;
using Spring.Messaging.Amqp.Rabbit.Connection;
using Spring.Messaging.Amqp.Rabbit.Core;
namespace Spring.RabbitQuickStart.BrokerConfiguration
{
+ /// <summary>
+ ///
+ /// </summary>
+ /// <author>Mark Pollack</author>
+ /// <author>Don McRae</author>
class Program
{
static void Main(string[] args)
@@ -14,13 +39,17 @@ static void Main(string[] args)
{
IAmqpAdmin amqpAdmin = new RabbitAdmin(connectionFactory);
- var marketDataQueue = new Queue("APP.STOCK.MARKETDATA");
- amqpAdmin.DeclareQueue(marketDataQueue);
+ //Each queue is automatically bound to the default direct exchange.
+ amqpAdmin.DeclareQueue(new Queue(ConfigurationManager.AppSettings["STOCK_REQUEST_QUEUE_NAME"]));
+ amqpAdmin.DeclareQueue(new Queue(ConfigurationManager.AppSettings["STOCK_RESPONSE_QUEUE_NAME"]));
- amqpAdmin.DeclareQueue(new Queue("APP.STOCK.REQUEST"));
- amqpAdmin.DeclareQueue(new Queue("APP.STOCK.JOE"));
+ TopicExchange mktDataExchange = new TopicExchange(ConfigurationManager.AppSettings["MARKET_DATA_EXCHANGE_NAME"], false, false);
+ amqpAdmin.DeclareExchange(mktDataExchange);
+ Queue mktDataQueue = new Queue(ConfigurationManager.AppSettings["MARKET_DATA_QUEUE_NAME"]);
+ amqpAdmin.DeclareQueue(mktDataQueue);
- //Each queue is automatically bound to the default direct exchange.
+ //Create the Exchange for MarketData Requests if it does not already exist.
+ amqpAdmin.DeclareBinding(BindingBuilder.Bind(mktDataQueue).To(mktDataExchange).With(ConfigurationManager.AppSettings["MARKET_DATA_ROUTING_KEY"]));
Console.WriteLine("Queues and exchanges have been declared.");
Console.WriteLine("Press 'enter' to exit");
View
46 ...bitQuickStart.BrokerConfiguration/Spring.RabbitQuickStart.BrokerConfiguration.2010.csproj
@@ -54,15 +54,37 @@
</PropertyGroup>
<ItemGroup>
<Reference Include="Common.Logging">
- <HintPath>..\..\..\..\..\packages\Common.Logging.2.0.0\lib\2.0\Common.Logging.dll</HintPath>
+ <HintPath>..\..\..\..\packages\Common.Logging.2.0.0\lib\2.0\Common.Logging.dll</HintPath>
</Reference>
<Reference Include="RabbitMQ.Client">
- <HintPath>..\..\..\..\..\packages\RabbitMQ.Client.2.5.1\lib\net30\RabbitMQ.Client.dll</HintPath>
+ <HintPath>..\..\..\..\packages\RabbitMQ.Client.2.5.1\lib\net30\RabbitMQ.Client.dll</HintPath>
+ </Reference>
+ <Reference Include="Spring.Aop">
+ <HintPath>..\..\..\..\packages\Spring.Aop.1.3.2\lib\net40\Spring.Aop.dll</HintPath>
</Reference>
<Reference Include="Spring.Core">
- <HintPath>..\..\..\..\..\packages\Spring.Core.1.3.2\lib\net40\Spring.Core.dll</HintPath>
+ <HintPath>..\..\..\..\packages\Spring.Core.1.3.2\lib\net40\Spring.Core.dll</HintPath>
+ </Reference>
+ <Reference Include="Spring.Data">
+ <HintPath>..\..\..\..\packages\Spring.Data.1.3.2\lib\net40\Spring.Data.dll</HintPath>
+ </Reference>
+ <Reference Include="Spring.Erlang">
+ <HintPath>..\..\..\..\packages\Spring.Messaging.Erlang.1.0\lib\net40\Spring.Erlang.dll</HintPath>
+ </Reference>
+ <Reference Include="Spring.Messaging.Amqp">
+ <HintPath>..\..\..\..\packages\Spring.Messaging.Amqp.1.0\lib\net40\Spring.Messaging.Amqp.dll</HintPath>
+ </Reference>
+ <Reference Include="Spring.Messaging.Amqp.Rabbit">
+ <HintPath>..\..\..\..\packages\Spring.Messaging.Amqp.Rabbit.1.0\lib\net40\Spring.Messaging.Amqp.Rabbit.dll</HintPath>
+ </Reference>
+ <Reference Include="Spring.Messaging.Amqp.Rabbit.Admin">
+ <HintPath>..\..\..\..\packages\Spring.Messaging.Amqp.Rabbit.Admin.1.0\lib\net40\Spring.Messaging.Amqp.Rabbit.Admin.dll</HintPath>
+ </Reference>
+ <Reference Include="Spring.Threading">
+ <HintPath>..\..\..\..\packages\Spring.Threading.1.0\lib\Spring.Threading.dll</HintPath>
</Reference>
<Reference Include="System" />
+ <Reference Include="System.configuration" />
<Reference Include="System.Data" />
<Reference Include="System.Xml" />
</ItemGroup>
@@ -75,24 +97,6 @@
<None Include="packages.config" />
</ItemGroup>
<ItemGroup>
- <ProjectReference Include="..\..\..\..\..\src\Spring.Erlang\Spring.Erlang.2010.csproj">
- <Project>{2619BBAC-1C37-4AE7-923F-E40EB7805132}</Project>
- <Name>Spring.Erlang.2010</Name>
- </ProjectReference>
- <ProjectReference Include="..\..\..\..\..\src\Spring.Messaging.Amqp.Rabbit.Admin\Spring.Messaging.Amqp.Rabbit.Admin.2010.csproj">
- <Project>{EBC1D070-FC8A-4EAD-B2A7-3AC25AB62507}</Project>
- <Name>Spring.Messaging.Amqp.Rabbit.Admin.2010</Name>
- </ProjectReference>
- <ProjectReference Include="..\..\..\..\..\src\Spring.Messaging.Amqp.Rabbit\Spring.Messaging.Amqp.Rabbit.2010.csproj">
- <Project>{1B1394DA-24D3-47FE-84CA-7E33B077F686}</Project>
- <Name>Spring.Messaging.Amqp.Rabbit.2010</Name>
- </ProjectReference>
- <ProjectReference Include="..\..\..\..\..\src\Spring.Messaging.Amqp\Spring.Messaging.Amqp.2010.csproj">
- <Project>{96CD9010-9DDF-4D13-892A-5D60F01F3C90}</Project>
- <Name>Spring.Messaging.Amqp.2010</Name>
- </ProjectReference>
- </ItemGroup>
- <ItemGroup>
<BootstrapperPackage Include="Microsoft.Net.Client.3.5">
<Visible>False</Visible>
<ProductName>.NET Framework 3.5 SP1 Client Profile</ProductName>
View
9 Spring.RabbitQuickStart/src/Spring/Spring.RabbitQuickStart.BrokerConfiguration/app.config
@@ -1,5 +1,14 @@
<?xml version="1.0" encoding="utf-8"?>
<configuration>
+
+ <appSettings>
+ <add key="MARKET_DATA_EXCHANGE_NAME" value="APP.STOCK.MARKETDATA" />
+ <add key="STOCK_REQUEST_QUEUE_NAME" value="APP.STOCK.REQUEST" />
+ <add key="STOCK_RESPONSE_QUEUE_NAME" value="APP.STOCK.JOE" />
+ <add key="MARKET_DATA_QUEUE_NAME" value="APP.STOCK.MARKETDATA" />
+ <add key="MARKET_DATA_ROUTING_KEY" value="APP.STOCK.QUOTES.#" />
+ </appSettings>
+
<startup>
<supportedRuntime version="v4.0" sku=".NETFramework,Version=v4.0" />
</startup>
View
5 Spring.RabbitQuickStart/src/Spring/Spring.RabbitQuickStart.Client/Config/Messaging.xml
@@ -5,7 +5,6 @@
</object>
-
<!-- Rabbit based implementation of technology neutral IStockServiceGateway -->
<object name="StockServiceGateway" type="Spring.RabbitQuickStart.Client.Gateways.RabbitStockServiceGateway, Spring.RabbitQuickStart.Client">
<property name="RabbitTemplate" ref="RabbitTemplate"/>
@@ -14,12 +13,10 @@
<object name="RabbitTemplate" type="Spring.Messaging.Amqp.Rabbit.Core.RabbitTemplate, Spring.Messaging.Amqp.Rabbit">
<property name="ConnectionFactory" ref="ConnectionFactory"/>
- <property name="Queue" value="APP.STOCK.REQUEST"/>
<property name="RoutingKey" value="APP.STOCK.REQUEST"/>
<property name="MessageConverter" ref="JsonMessageConverter"/>
</object>
-
<object name="MessageListenerContainer" type="Spring.Messaging.Amqp.Rabbit.Listener.SimpleMessageListenerContainer, Spring.Messaging.Amqp.Rabbit">
<property name="ConnectionFactory" ref="ConnectionFactory"/>
<property name="QueueNames" value="APP.STOCK.MARKETDATA,APP.STOCK.JOE"/>
@@ -27,8 +24,6 @@
<property name="MessageListener" ref="MessageListenerAdapter"/>
</object>
-
-
<!-- Plain object message handler -->
<object id="MessageListenerAdapter" type="Spring.Messaging.Amqp.Rabbit.Listener.Adapter.MessageListenerAdapter, Spring.Messaging.Amqp.Rabbit">
<property name="HandlerObject" ref="StockAppHandler"/>
View
31 ...bbitQuickStart/src/Spring/Spring.RabbitQuickStart.Client/Gateways/IStockServiceGateway.cs
@@ -0,0 +1,31 @@
+
+
+#region License
+
+/*
+ * Copyright 2002-2008 the original author or authors.
+ *
+ * Licensed 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.
+ */
+
+#endregion
+
+using Spring.RabbitQuickStart.Common.Data;
+
+namespace Spring.RabbitQuickStart.Client.Gateways
+{
+ public interface IStockServiceGateway
+ {
+ void Send(TradeRequest tradeRequest);
+ }
+}
View
36 ...uickStart/src/Spring/Spring.RabbitQuickStart.Client/Gateways/RabbitStockServiceGateway.cs
@@ -1,5 +1,22 @@
+#region License
+/*
+ * Copyright 2002-2010 the original author or authors.
+ *
+ * Licensed 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.
+ */
+#endregion
using System;
using Spring.Messaging.Amqp.Core;
@@ -9,7 +26,12 @@
namespace Spring.RabbitQuickStart.Client.Gateways
{
- public class RabbitStockServiceGateway : RabbitGatewaySupport, IStockService
+ /// <summary>
+ ///
+ /// </summary>
+ /// <author>Mark Pollack</author>
+ /// <author>Don McRae</author>
+ public class RabbitStockServiceGateway : RabbitGatewaySupport, IStockServiceGateway
{
private string defaultReplyToQueue;
@@ -20,8 +42,6 @@ public string DefaultReplyToQueue
public void Send(TradeRequest tradeRequest)
{
-
- //Asynchronous return
RabbitTemplate.ConvertAndSend(tradeRequest, delegate(Message message)
{
message.MessageProperties.ReplyTo = new Address(defaultReplyToQueue);
@@ -29,14 +49,6 @@ public void Send(TradeRequest tradeRequest)
return message;
});
- //Synchronous return - required modification of IStockServer and this method to return the
- //TradeResponse.
- //var res = RabbitTemplate.ConvertSendAndReceive(tradeRequest, delegate(Message message)
- //{
- // //message.MessageProperties.ReplyTo = new Address(defaultReplyToQueue);
- // message.MessageProperties.CorrelationId = new Guid().ToByteArray();
- // return message;
- //});
- }
+ }
}
}
View
15 ...ng.RabbitQuickStart/src/Spring/Spring.RabbitQuickStart.Client/Handlers/StockAppHandler.cs
@@ -25,6 +25,11 @@
namespace Spring.RabbitQuickStart.Client.Handlers
{
+ /// <summary>
+ ///
+ /// </summary>
+ /// <author>Mark Pollack</author>
+ /// <author>Don McRae</author>
public class StockAppHandler
{
#region Logging Definition
@@ -42,19 +47,17 @@ public StockController StockController
set { stockController = value; }
}
- public void Handle(Hashtable data)
+ public void Handle(Quote quote)
{
- log.Info(string.Format("Received market data. Ticker = {0}, Price = {1}", data["TICKER"], data["PRICE"]));
-
+ log.Info(string.Format("Received market data. Ticker = {0}, Price = {1}", quote.Stock.Ticker, quote.Price));
// forward to controller to update view
- stockController.UpdateMarketData(data);
-
+ stockController.UpdateMarketData(quote);
}
-
public void Handle(TradeResponse tradeResponse)
{
log.Info(string.Format("Received trade resonse. Ticker = {0}, Price = {1}", tradeResponse.Ticker, tradeResponse.Price));
+ // forward to controller to update view
stockController.UpdateTrade(tradeResponse);
}
View
5 Spring.RabbitQuickStart/src/Spring/Spring.RabbitQuickStart.Client/Program.cs
@@ -48,11 +48,6 @@ static void Main()
Application.SetCompatibleTextRenderingDefault(false);
using (IApplicationContext ctx = ContextRegistry.GetContext())
{
- //Autostart should be used in messaging.xml instead
- Spring.Messaging.Amqp.Rabbit.Listener.SimpleMessageListenerContainer container =
- ContextRegistry.GetContext().GetObject("MessageListenerContainer") as Spring.Messaging.Amqp.Rabbit.Listener.SimpleMessageListenerContainer;
- container.Start();
-
StockForm stockForm = new StockForm();
Application.ThreadException += ThreadException;
Application.Run(stockForm);
View
31 ...tart/src/Spring/Spring.RabbitQuickStart.Client/Spring.RabbitQuickStart.Client.2010.csproj
@@ -56,26 +56,32 @@
</PropertyGroup>
<ItemGroup>
<Reference Include="Common.Logging">
- <HintPath>..\..\..\..\..\packages\Common.Logging.2.0.0\lib\2.0\Common.Logging.dll</HintPath>
+ <HintPath>..\..\..\..\packages\Common.Logging.2.0.0\lib\2.0\Common.Logging.dll</HintPath>
</Reference>
<Reference Include="Newtonsoft.Json">
- <HintPath>..\..\..\..\..\packages\Newtonsoft.Json.4.0.2\lib\net40\Newtonsoft.Json.dll</HintPath>
+ <HintPath>..\..\..\..\packages\Newtonsoft.Json.4.0.2\lib\net40\Newtonsoft.Json.dll</HintPath>
</Reference>
<Reference Include="RabbitMQ.Client">
- <HintPath>..\..\..\..\..\packages\RabbitMQ.Client.2.5.1\lib\net30\RabbitMQ.Client.dll</HintPath>
+ <HintPath>..\..\..\..\packages\RabbitMQ.Client.2.5.1\lib\net30\RabbitMQ.Client.dll</HintPath>
</Reference>
<Reference Include="Spring.Aop">
- <HintPath>..\..\..\..\..\packages\Spring.Aop.1.3.2\lib\net40\Spring.Aop.dll</HintPath>
+ <HintPath>..\..\..\..\packages\Spring.Aop.1.3.2\lib\net40\Spring.Aop.dll</HintPath>
</Reference>
<Reference Include="Spring.Core">
- <HintPath>..\..\..\..\..\packages\Spring.Core.1.3.2\lib\net40\Spring.Core.dll</HintPath>
+ <HintPath>..\..\..\..\packages\Spring.Core.1.3.2\lib\net40\Spring.Core.dll</HintPath>
</Reference>
<Reference Include="Spring.Data">
- <HintPath>..\..\..\..\..\packages\Spring.Data.1.3.2\lib\net40\Spring.Data.dll</HintPath>
+ <HintPath>..\..\..\..\packages\Spring.Data.1.3.2\lib\net40\Spring.Data.dll</HintPath>
+ </Reference>
+ <Reference Include="Spring.Messaging.Amqp">
+ <HintPath>..\..\..\..\packages\Spring.Messaging.Amqp.1.0\lib\net40\Spring.Messaging.Amqp.dll</HintPath>
+ </Reference>
+ <Reference Include="Spring.Messaging.Amqp.Rabbit">
+ <HintPath>..\..\..\..\packages\Spring.Messaging.Amqp.Rabbit.1.0\lib\net40\Spring.Messaging.Amqp.Rabbit.dll</HintPath>
</Reference>
<Reference Include="Spring.Threading, Version=1.1.2.20125, Culture=neutral, processorArchitecture=MSIL">
<SpecificVersion>False</SpecificVersion>
- <HintPath>..\..\..\..\..\lib\net\3.5\Spring.Threading.dll</HintPath>
+ <HintPath>..\..\..\..\packages\Spring.Threading.1.0\lib\Spring.Threading.dll</HintPath>
</Reference>
<Reference Include="System" />
<Reference Include="System.Data" />
@@ -84,8 +90,7 @@
<Reference Include="System.Xml" />
</ItemGroup>
<ItemGroup>
- <Compile Include="Gateways\IStockService.cs" />
- <Compile Include="Gateways\ISyncStockService.cs" />
+ <Compile Include="Gateways\IStockServiceGateway.cs" />
<Compile Include="Gateways\RabbitStockServiceGateway.cs" />
<Compile Include="Handlers\StockAppHandler.cs" />
<Compile Include="Program.cs" />
@@ -114,14 +119,6 @@
</EmbeddedResource>
</ItemGroup>
<ItemGroup>
- <ProjectReference Include="..\..\..\..\..\src\Spring.Messaging.Amqp.Rabbit\Spring.Messaging.Amqp.Rabbit.2010.csproj">
- <Project>{1B1394DA-24D3-47FE-84CA-7E33B077F686}</Project>
- <Name>Spring.Messaging.Amqp.Rabbit.2010</Name>
- </ProjectReference>
- <ProjectReference Include="..\..\..\..\..\src\Spring.Messaging.Amqp\Spring.Messaging.Amqp.2010.csproj">
- <Project>{96CD9010-9DDF-4D13-892A-5D60F01F3C90}</Project>
- <Name>Spring.Messaging.Amqp.2010</Name>
- </ProjectReference>
<ProjectReference Include="..\Spring.RabbitQuickStart.Common\Spring.RabbitQuickStart.Common.2010.csproj">
<Project>{DE909872-61DE-48EC-BD1A-8DEE4D993F5B}</Project>
<Name>Spring.RabbitQuickStart.Common.2010</Name>
View
13 Spring.RabbitQuickStart/src/Spring/Spring.RabbitQuickStart.Client/UI/StockController.cs
@@ -29,11 +29,13 @@ namespace Spring.RabbitQuickStart.Client.UI
/// Handles requests from the UI and forwards them to the remote service. Messages recieved from
/// the service routed through this controller to update the UI.
/// </summary>
+ /// <author>Mark Pollack</author>
+ /// <author>Don McRae</author>
public class StockController
{
private StockForm stockForm;
-
- private IStockService stockService;
+
+ private IStockServiceGateway stockService;
public StockForm StockForm
{
@@ -41,7 +43,7 @@ public StockForm StockForm
set { stockForm = value; }
}
- public IStockService StockService
+ public IStockServiceGateway StockService
{
get { return stockService; }
set { stockService = value; }
@@ -61,9 +63,9 @@ public void SendTradeRequest()
stockService.Send(tradeRequest);
}
- public void UpdateMarketData(IDictionary marketDataDict)
+ public void UpdateMarketData(Quote quote)
{
- stockForm.UpdateMarketData(marketDataDict);
+ stockForm.UpdateMarketData(quote);
}
public void UpdateTrade(TradeResponse tradeResponse)
@@ -71,5 +73,6 @@ public void UpdateTrade(TradeResponse tradeResponse)
stockForm.UpdateTrade(tradeResponse);
}
+
}
}
View
90 Spring.RabbitQuickStart/src/Spring/Spring.RabbitQuickStart.Client/UI/StockForm.cs
@@ -24,9 +24,17 @@
using Common.Logging;
using Spring.Context.Support;
using Spring.RabbitQuickStart.Common.Data;
+using Spring.Messaging.Amqp.Core;
+using Spring.Messaging.Amqp.Rabbit.Connection;
+using Spring.Messaging.Amqp.Rabbit.Core;
namespace Spring.RabbitQuickStart.Client.UI
{
+ /// <summary>
+ ///
+ /// </summary>
+ /// <author>Mark Pollack</author>
+ /// <author>Don McRae</author>
public partial class StockForm : Form
{
#region Logging Definition
@@ -36,6 +44,7 @@ public partial class StockForm : Form
#endregion
private StockController stockController;
+ private string _currentBinding;
public StockForm()
{
@@ -67,13 +76,88 @@ public void UpdateTrade(TradeResponse trade)
}));
}
- public void UpdateMarketData(IDictionary marketDataDict)
+ public void UpdateMarketData(Quote quote)
{
Invoke(new MethodInvoker(
delegate
- {
- marketDataListBox.Items.Add(marketDataDict["TICKER"] + " " + marketDataDict["PRICE"]);
+ {
+ marketDataListBox.Items.Add(quote.Stock.StockExchange.ToString() + "." + quote.Stock.Ticker + " " + quote.Price);
}));
}
+
+ private void btnApply_Click(object sender, EventArgs e)
+ {
+ RebindQueue(txtRoutingKey.Text);
+ marketDataListBox.Items.Clear();
+ }
+
+ private void btnStop_Click(object sender, EventArgs e)
+ {
+ RebindQueue(string.Empty);
+ }
+
+ private void btnStart_Click(object sender, EventArgs e)
+ {
+ RebindQueue(txtRoutingKey.Text);
+ }
+
+ private void btnClear_Click(object sender, EventArgs e)
+ {
+ marketDataListBox.Items.Clear();
+ }
+
+ private void StockForm_Load(object sender, EventArgs e)
+ {
+ try
+ {
+ using (IConnectionFactory connectionFactory = new SingleConnectionFactory())
+ {
+ IAmqpAdmin amqpAdmin = new RabbitAdmin(connectionFactory);
+
+ TopicExchange mktDataExchange = new TopicExchange("APP.STOCK.MARKETDATA", false, false);
+ amqpAdmin.DeclareExchange(mktDataExchange);
+ Spring.Messaging.Amqp.Core.Queue mktDataQueue = new Spring.Messaging.Amqp.Core.Queue("APP.STOCK.MARKETDATA");
+ amqpAdmin.DeclareQueue(mktDataQueue);
+
+ //Create the Exchange for MarketData Requests if it does not already exist.
+ //amqpAdmin.DeclareBinding(BindingBuilder.Bind(mktDataQueue).To(mktDataExchange).With(_currentBinding));
+ //Set up initial binding
+ RebindQueue("APP.STOCK.QUOTES.nasdaq.*");
+ }
+ }
+ catch (Exception ex)
+ {
+ log.ErrorFormat("Uncaught application exception.", ex);
+ }
+ }
+
+ private void RebindQueue(string routingKey)
+ {
+ try
+ {
+ using (IConnectionFactory connectionFactory = new SingleConnectionFactory())
+ {
+ IAmqpAdmin amqpAdmin = new RabbitAdmin(connectionFactory);
+
+ TopicExchange mktDataExchange = new TopicExchange("APP.STOCK.MARKETDATA", false, false);
+ Spring.Messaging.Amqp.Core.Queue mktDataQueue = new Spring.Messaging.Amqp.Core.Queue("APP.STOCK.MARKETDATA");
+
+ if (!string.IsNullOrEmpty(_currentBinding))
+ amqpAdmin.RemoveBinding(BindingBuilder.Bind(mktDataQueue).To(mktDataExchange).With(_currentBinding));
+
+ _currentBinding = routingKey;
+ if (!string.IsNullOrEmpty(_currentBinding))
+ {
+ amqpAdmin.DeclareBinding(BindingBuilder.Bind(mktDataQueue).To(mktDataExchange).With(_currentBinding));
+ txtRoutingKey.Text = _currentBinding;
+ }
+ }
+
+ }
+ catch (Exception ex)
+ {
+ log.ErrorFormat("Uncaught application exception.", ex);
+ }
+ }
}
}
View
116 Spring.RabbitQuickStart/src/Spring/Spring.RabbitQuickStart.Client/UI/StockForm.designer.cs
@@ -32,14 +32,20 @@ private void InitializeComponent()
this.tradeRequestStatusTextBox = new System.Windows.Forms.TextBox();
this.marketDataListBox = new System.Windows.Forms.ListBox();
this.label1 = new System.Windows.Forms.Label();
+ this.btnStop = new System.Windows.Forms.Button();
+ this.btnStart = new System.Windows.Forms.Button();
+ this.btnClear = new System.Windows.Forms.Button();
+ this.label2 = new System.Windows.Forms.Label();
+ this.txtRoutingKey = new System.Windows.Forms.TextBox();
+ this.btnApply = new System.Windows.Forms.Button();
+ this.label3 = new System.Windows.Forms.Label();
this.SuspendLayout();
//
// tradeRequestButton
//
- this.tradeRequestButton.Location = new System.Drawing.Point(16, 15);
- this.tradeRequestButton.Margin = new System.Windows.Forms.Padding(4, 4, 4, 4);
+ this.tradeRequestButton.Location = new System.Drawing.Point(12, 12);
this.tradeRequestButton.Name = "tradeRequestButton";
- this.tradeRequestButton.Size = new System.Drawing.Size(180, 28);
+ this.tradeRequestButton.Size = new System.Drawing.Size(135, 23);
this.tradeRequestButton.TabIndex = 0;
this.tradeRequestButton.Text = "Send Trade Request";
this.tradeRequestButton.UseVisualStyleBackColor = true;
@@ -49,10 +55,9 @@ private void InitializeComponent()
//
this.tradeRequestStatusTextBox.Anchor = ((System.Windows.Forms.AnchorStyles)(((System.Windows.Forms.AnchorStyles.Top | System.Windows.Forms.AnchorStyles.Left)
| System.Windows.Forms.AnchorStyles.Right)));
- this.tradeRequestStatusTextBox.Location = new System.Drawing.Point(205, 16);
- this.tradeRequestStatusTextBox.Margin = new System.Windows.Forms.Padding(4, 4, 4, 4);
+ this.tradeRequestStatusTextBox.Location = new System.Drawing.Point(154, 13);
this.tradeRequestStatusTextBox.Name = "tradeRequestStatusTextBox";
- this.tradeRequestStatusTextBox.Size = new System.Drawing.Size(366, 22);
+ this.tradeRequestStatusTextBox.Size = new System.Drawing.Size(276, 20);
this.tradeRequestStatusTextBox.TabIndex = 1;
//
// marketDataListBox
@@ -62,35 +67,107 @@ private void InitializeComponent()
| System.Windows.Forms.AnchorStyles.Right)));
this.marketDataListBox.Font = new System.Drawing.Font("Courier New", 8.25F, System.Drawing.FontStyle.Regular, System.Drawing.GraphicsUnit.Point, ((byte)(177)));
this.marketDataListBox.FormattingEnabled = true;
- this.marketDataListBox.ItemHeight = 17;
- this.marketDataListBox.Location = new System.Drawing.Point(120, 53);
- this.marketDataListBox.Margin = new System.Windows.Forms.Padding(4, 4, 4, 4);
+ this.marketDataListBox.ItemHeight = 14;
+ this.marketDataListBox.Location = new System.Drawing.Point(90, 127);
this.marketDataListBox.Name = "marketDataListBox";
- this.marketDataListBox.Size = new System.Drawing.Size(451, 123);
+ this.marketDataListBox.Size = new System.Drawing.Size(339, 228);
this.marketDataListBox.TabIndex = 4;
//
// label1
//
this.label1.AutoSize = true;
- this.label1.Location = new System.Drawing.Point(16, 53);
- this.label1.Margin = new System.Windows.Forms.Padding(4, 0, 4, 0);
+ this.label1.Location = new System.Drawing.Point(9, 127);
this.label1.Name = "label1";
- this.label1.Size = new System.Drawing.Size(93, 17);
+ this.label1.Size = new System.Drawing.Size(72, 13);
this.label1.TabIndex = 5;
this.label1.Text = "Market Data :";
//
+ // btnStop
+ //
+ this.btnStop.Location = new System.Drawing.Point(90, 102);
+ this.btnStop.Name = "btnStop";
+ this.btnStop.Size = new System.Drawing.Size(75, 23);
+ this.btnStop.TabIndex = 6;
+ this.btnStop.Text = "Stop";
+ this.btnStop.UseVisualStyleBackColor = true;
+ this.btnStop.Click += new System.EventHandler(this.btnStop_Click);
+ //
+ // btnStart
+ //
+ this.btnStart.Location = new System.Drawing.Point(171, 102);
+ this.btnStart.Name = "btnStart";
+ this.btnStart.Size = new System.Drawing.Size(75, 23);
+ this.btnStart.TabIndex = 6;
+ this.btnStart.Text = "Start";
+ this.btnStart.UseVisualStyleBackColor = true;
+ this.btnStart.Click += new System.EventHandler(this.btnStart_Click);
+ //
+ // btnClear
+ //
+ this.btnClear.Location = new System.Drawing.Point(355, 102);
+ this.btnClear.Name = "btnClear";
+ this.btnClear.Size = new System.Drawing.Size(75, 23);
+ this.btnClear.TabIndex = 6;
+ this.btnClear.Text = "Clear";
+ this.btnClear.UseVisualStyleBackColor = true;
+ this.btnClear.Click += new System.EventHandler(this.btnClear_Click);
+ //
+ // label2
+ //
+ this.label2.AutoSize = true;
+ this.label2.Location = new System.Drawing.Point(12, 61);
+ this.label2.Name = "label2";
+ this.label2.Size = new System.Drawing.Size(71, 13);
+ this.label2.TabIndex = 5;
+ this.label2.Text = "Routing Key :";
+ //
+ // txtRoutingKey
+ //
+ this.txtRoutingKey.Anchor = ((System.Windows.Forms.AnchorStyles)(((System.Windows.Forms.AnchorStyles.Top | System.Windows.Forms.AnchorStyles.Left)
+ | System.Windows.Forms.AnchorStyles.Right)));
+ this.txtRoutingKey.Location = new System.Drawing.Point(90, 58);
+ this.txtRoutingKey.Name = "txtRoutingKey";
+ this.txtRoutingKey.Size = new System.Drawing.Size(258, 20);
+ this.txtRoutingKey.TabIndex = 1;
+ //
+ // btnApply
+ //
+ this.btnApply.Location = new System.Drawing.Point(354, 58);
+ this.btnApply.Name = "btnApply";
+ this.btnApply.Size = new System.Drawing.Size(75, 23);
+ this.btnApply.TabIndex = 6;
+ this.btnApply.Text = "Apply";
+ this.btnApply.UseVisualStyleBackColor = true;
+ this.btnApply.Click += new System.EventHandler(this.btnApply_Click);
+ //
+ // label3
+ //
+ this.label3.AutoSize = true;
+ this.label3.Location = new System.Drawing.Point(93, 81);
+ this.label3.Name = "label3";
+ this.label3.Size = new System.Drawing.Size(202, 13);
+ this.label3.TabIndex = 5;
+ this.label3.Text = "i.e. APP.STOCK.QUOTES.nasdaq.MSFT";
+ //
// StockForm
//
- this.AutoScaleDimensions = new System.Drawing.SizeF(8F, 16F);
+ this.AutoScaleDimensions = new System.Drawing.SizeF(6F, 13F);
this.AutoScaleMode = System.Windows.Forms.AutoScaleMode.Font;
- this.ClientSize = new System.Drawing.Size(589, 200);
+ this.ClientSize = new System.Drawing.Size(442, 384);
+ this.Controls.Add(this.btnApply);
+ this.Controls.Add(this.btnClear);
+ this.Controls.Add(this.btnStart);
+ this.Controls.Add(this.btnStop);
+ this.Controls.Add(this.label2);
+ this.Controls.Add(this.label3);
this.Controls.Add(this.label1);
this.Controls.Add(this.marketDataListBox);
+ this.Controls.Add(this.txtRoutingKey);
this.Controls.Add(this.tradeRequestStatusTextBox);
this.Controls.Add(this.tradeRequestButton);
- this.Margin = new System.Windows.Forms.Padding(4, 4, 4, 4);
this.Name = "StockForm";
this.Text = "TradeForm";
+ this.Load += new System.EventHandler(this.StockForm_Load);
this.ResumeLayout(false);
this.PerformLayout();
@@ -102,5 +179,12 @@ private void InitializeComponent()
private System.Windows.Forms.TextBox tradeRequestStatusTextBox;
private System.Windows.Forms.ListBox marketDataListBox;
private System.Windows.Forms.Label label1;
+ private System.Windows.Forms.Button btnStop;
+ private System.Windows.Forms.Button btnStart;
+ private System.Windows.Forms.Button btnClear;
+ private System.Windows.Forms.Label label2;
+ private System.Windows.Forms.TextBox txtRoutingKey;
+ private System.Windows.Forms.Button btnApply;
+ private System.Windows.Forms.Label label3;
}
}
View
4 Spring.RabbitQuickStart/src/Spring/Spring.RabbitQuickStart.Client/UI/StockForm.resx
@@ -112,9 +112,9 @@
<value>2.0</value>
</resheader>
<resheader name="reader">
- <value>System.Resources.ResXResourceReader, System.Windows.Forms, Version=2.0.0.0, Culture=neutral, PublicKeyToken=b77a5c561934e089</value>
+ <value>System.Resources.ResXResourceReader, System.Windows.Forms, Version=4.0.0.0, Culture=neutral, PublicKeyToken=b77a5c561934e089</value>
</resheader>
<resheader name="writer">
- <value>System.Resources.ResXResourceWriter, System.Windows.Forms, Version=2.0.0.0, Culture=neutral, PublicKeyToken=b77a5c561934e089</value>
+ <value>System.Resources.ResXResourceWriter, System.Windows.Forms, Version=4.0.0.0, Culture=neutral, PublicKeyToken=b77a5c561934e089</value>
</resheader>
</root>
View
BIN  ...Spring/Spring.RabbitQuickStart.Client/bin/Debug/Spring.RabbitQuickStart.Client.vshost.exe
Binary file not shown
View
61 ...Spring.RabbitQuickStart.Client/bin/Debug/Spring.RabbitQuickStart.Client.vshost.exe.config
@@ -0,0 +1,61 @@
+<?xml version="1.0" encoding="utf-8"?>
+<configuration>
+ <configSections>
+ <sectionGroup name="spring">
+ <section name="context" type="Spring.Context.Support.ContextHandler, Spring.Core" />
+ <!--
+ <section name="parsers" type="Spring.Context.Support.NamespaceParsersSectionHandler, Spring.Core"/>
+ -->
+ </sectionGroup>
+ <sectionGroup name="common">
+ <section name="logging" type="Common.Logging.ConfigurationSectionHandler, Common.Logging" />
+ </sectionGroup>
+ </configSections>
+ <spring>
+ <context>
+ <resource uri="~/Config/Messaging.xml" />
+ <resource uri="~/Config/Application.xml" />
+ </context>
+ <!--
+ <parsers>
+
+ <parser type="Spring.Messaging.Nms.Config.NmsNamespaceParser, Spring.Messaging.Nms" />
+
+ </parsers>
+ -->
+ </spring>
+ <common>
+ <logging>
+ <factoryAdapter type="Common.Logging.Simple.ConsoleOutLoggerFactoryAdapter, Common.Logging">
+ <arg key="showLogName" value="true" />
+ <arg key="showDataTime" value="true" />
+ <arg key="level" value="DEBUG" />
+ <arg key="dateTimeFormat" value="yyyy/MM/dd HH:mm:ss:fff" />
+ </factoryAdapter>
+ </logging>
+ </common>
+ <startup>
+ <supportedRuntime version="v4.0" sku=".NETFramework,Version=v4.0" />
+ </startup>
+ <runtime>
+ <assemblyBinding xmlns="urn:schemas-microsoft-com:asm.v1">
+ <dependentAssembly>
+ <assemblyIdentity name="Spring.Aop" publicKeyToken="65e474d141e25e07" culture="neutral" />
+ <bindingRedirect oldVersion="0.0.0.0-1.3.1.40711" newVersion="1.3.1.40711" />
+ </dependentAssembly>
+ <dependentAssembly>
+ <assemblyIdentity name="Spring.Core" publicKeyToken="65e474d141e25e07" culture="neutral" />
+ <bindingRedirect oldVersion="0.0.0.0-1.3.1.40711" newVersion="1.3.1.40711" />
+ </dependentAssembly>
+ </assemblyBinding>
+
+ <assemblyBinding xmlns="urn:schemas-microsoft-com:asm.v1">
+ <dependentAssembly>
+ <assemblyIdentity name="Common.Logging"
+ publicKeyToken="AF08829B84F0328E" />
+ <bindingRedirect oldVersion="1.2.0.0"
+ newVersion="2.0.0.0"/>
+ </dependentAssembly>
+ </assemblyBinding>
+ </runtime>
+</configuration>
View
11 ...ring.RabbitQuickStart.Client/bin/Debug/Spring.RabbitQuickStart.Client.vshost.exe.manifest
@@ -0,0 +1,11 @@
+<?xml version="1.0" encoding="UTF-8" standalone="yes"?>
+<assembly xmlns="urn:schemas-microsoft-com:asm.v1" manifestVersion="1.0">
+ <assemblyIdentity version="1.0.0.0" name="MyApplication.app"/>
+ <trustInfo xmlns="urn:schemas-microsoft-com:asm.v2">
+ <security>
+ <requestedPrivileges xmlns="urn:schemas-microsoft-com:asm.v3">
+ <requestedExecutionLevel level="asInvoker" uiAccess="false"/>
+ </requestedPrivileges>
+ </security>
+ </trustInfo>
+</assembly>
View
BIN  ...g/Spring.RabbitQuickStart.Client/obj/Debug/DesignTimeResolveAssemblyReferencesInput.cache
Binary file not shown
View
65 Spring.RabbitQuickStart/src/Spring/Spring.RabbitQuickStart.Common/Data/Quote.cs
@@ -0,0 +1,65 @@
+#region License
+
+/*
+ * Copyright 2002-2010 the original author or authors.
+ *
+ * Licensed 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.
+ */
+
+#endregion
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Text;
+
+namespace Spring.RabbitQuickStart.Common.Data
+{
+ /// <summary>
+ /// Simple POCO class that represents a quote
+ /// </summary>
+ /// <author>Mark Pollack</author>
+ /// <author>Don McRae</author>
+ public class Quote
+ {
+ public Stock Stock { get; set; }
+ public String Price { get; set; }
+ public long Timestamp { get; set; }
+
+ public Quote()
+ : this(null, null)
+ {
+
+ }
+
+ public Quote(Stock stock, String price)
+ : this(stock, price, DateTime.Now.Ticks)
+ {
+ }
+
+ public Quote(Stock stock, String price, long timestamp) {
+ this.Stock = stock;
+ this.Price = price;
+ this.Timestamp = timestamp;
+ }
+
+ public String getTimeString() {
+ DateTime date = new DateTime(Timestamp);
+ return date.ToShortTimeString();
+ }
+
+
+ public override String ToString() {
+ return "Quote [time=" + getTimeString() + ", stock=" + Stock + ", price=" + Price + "]";
+ }
+ }
+}
View
50 Spring.RabbitQuickStart/src/Spring/Spring.RabbitQuickStart.Common/Data/Stock.cs
@@ -0,0 +1,50 @@
+#region License
+
+/*
+ * Copyright 2002-2010 the original author or authors.
+ *
+ * Licensed 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.
+ */
+
+#endregion
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Text;
+
+namespace Spring.RabbitQuickStart.Common.Data
+{
+ /// <summary>
+ /// Simple POCO class that represents a stock
+ /// </summary>
+ /// <author>Mark Pollack</author>
+ /// <author>Don McRae</author>
+ public class Stock
+ {
+ public String Ticker { get; set; }
+ public StockExchange StockExchange { get; set; }
+
+ // For de-seialization:
+ public Stock() {
+ }
+
+ public Stock(StockExchange stockExchange, String ticker) {
+ this.StockExchange = stockExchange;
+ this.Ticker = ticker;
+ }
+
+ public override String ToString() {
+ return "Stock [ticker=" + Ticker + ", stockExchange=" + StockExchange + "]";
+ }
+ }
+}
View
32 Spring.RabbitQuickStart/src/Spring/Spring.RabbitQuickStart.Common/Data/StockExchange.cs
@@ -0,0 +1,32 @@
+#region License
+
+/*
+ * Copyright 2002-2010 the original author or authors.
+ *
+ * Licensed 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.
+ */
+
+#endregion
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Text;
+
+namespace Spring.RabbitQuickStart.Common.Data
+{
+ public enum StockExchange
+ {
+ nyse,
+ nasdaq
+ };
+}
View
1  Spring.RabbitQuickStart/src/Spring/Spring.RabbitQuickStart.Common/Data/TradeRequest.cs
@@ -24,6 +24,7 @@ namespace Spring.RabbitQuickStart.Common.Data
/// Simple POCO class that represents a simple trade request
/// </summary>
/// <author>Mark Pollack</author>
+ /// <author>Don McRae</author>
public class TradeRequest
{
private string ticker;
View
3  Spring.RabbitQuickStart/src/Spring/Spring.RabbitQuickStart.Common/Data/TradeResponse.cs
@@ -21,9 +21,10 @@
namespace Spring.RabbitQuickStart.Common.Data
{
/// <summary>
- ///
+ /// Simple POCO class that represents a simple trade response
/// </summary>
/// <author>Mark Pollack</author>
+ /// <author>Don McRae</author>
public class TradeResponse
{
private string ticker;
View
3  ...tart/src/Spring/Spring.RabbitQuickStart.Common/Spring.RabbitQuickStart.Common.2010.csproj
@@ -58,6 +58,9 @@