You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@activemq.apache.org by ch...@apache.org on 2006/03/04 09:19:10 UTC
svn commit: r383072 [1/2] - in /incubator/activemq/trunk/openwire-dotnet: ./
src/ tests/ tests/ActiveMQ/ tests/ActiveMQ/OpenWire/
Author: chirino
Date: Sat Mar 4 00:19:09 2006
New Revision: 383072
URL: http://svn.apache.org/viewcvs?rev=383072&view=rev
Log:
Get it to compile after refactor
Modified:
incubator/activemq/trunk/openwire-dotnet/OpenWire.build
incubator/activemq/trunk/openwire-dotnet/src/src.csproj
incubator/activemq/trunk/openwire-dotnet/tests/ActiveMQ/AsyncConsumeTest.cs
incubator/activemq/trunk/openwire-dotnet/tests/ActiveMQ/BadConsumeTest.cs
incubator/activemq/trunk/openwire-dotnet/tests/ActiveMQ/BytesMessageTest.cs
incubator/activemq/trunk/openwire-dotnet/tests/ActiveMQ/ClientTest.cs
incubator/activemq/trunk/openwire-dotnet/tests/ActiveMQ/CommandTest.cs
incubator/activemq/trunk/openwire-dotnet/tests/ActiveMQ/ConsumerTest.cs
incubator/activemq/trunk/openwire-dotnet/tests/ActiveMQ/EndianTest.cs
incubator/activemq/trunk/openwire-dotnet/tests/ActiveMQ/JMSPropertyTest.cs
incubator/activemq/trunk/openwire-dotnet/tests/ActiveMQ/MapMessageTest.cs
incubator/activemq/trunk/openwire-dotnet/tests/ActiveMQ/OpenWire/BooleanStreamTest.cs
incubator/activemq/trunk/openwire-dotnet/tests/ActiveMQ/TestMain.cs
incubator/activemq/trunk/openwire-dotnet/tests/ActiveMQ/TestSupport.cs
incubator/activemq/trunk/openwire-dotnet/tests/ActiveMQ/TransactionTest.cs
incubator/activemq/trunk/openwire-dotnet/tests/tests.csproj
Modified: incubator/activemq/trunk/openwire-dotnet/OpenWire.build
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/OpenWire.build?rev=383072&r1=383071&r2=383072&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/OpenWire.build (original)
+++ incubator/activemq/trunk/openwire-dotnet/OpenWire.build Sat Mar 4 00:19:09 2006
@@ -148,8 +148,8 @@
<exclude name="scvs.exe" />
</fileset>
</copy>
- <!-- build OpenWire.Client assembly -->
- <nant buildfile="src/OpenWire.Client/OpenWire.Client.build" target="build" />
+ <!-- build ActiveMQ assembly -->
+ <nant buildfile="src/ActiveMQ/OpenWire.Client.build" target="build" />
<!-- build task assemblies -->
<nant target="build">
<buildfiles refid="tas.core"/>
@@ -165,8 +165,8 @@
</target>
<target name="test" depends="build">
- <!-- build OpenWire.Client.Tests assembly -->
- <nant buildfile="tests/OpenWire.Client/OpenWire.Client.build" target="test" />
+ <!-- build ActiveMQ Tests assembly -->
+ <nant buildfile="tests/ActiveMQ/OpenWire.Client.build" target="test" />
<!-- build tests for task assemblies -->
<nant target="build">
<buildfiles refid="tas.core.tests"/>
Modified: incubator/activemq/trunk/openwire-dotnet/src/src.csproj
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/src.csproj?rev=383072&r1=383071&r2=383072&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/src.csproj (original)
+++ incubator/activemq/trunk/openwire-dotnet/src/src.csproj Sat Mar 4 00:19:09 2006
@@ -1,186 +1,186 @@
-<Project xmlns="http://schemas.microsoft.com/developer/msbuild/2003" DefaultTargets="Build">
- <PropertyGroup>
- <Configuration Condition=" '$(Configuration)' == '' ">Debug</Configuration>
- <Platform Condition=" '$(Platform)' == '' ">AnyCPU</Platform>
- <ProductVersion>8.0.30703</ProductVersion>
- <SchemaVersion>2.0</SchemaVersion>
- <ProjectGuid>{F7BA9EF7-ADF7-40EF-9A9E-206649DBB10C}</ProjectGuid>
- <OutputType>Library</OutputType>
- <RootNamespace>src</RootNamespace>
- <AssemblyName>src</AssemblyName>
- <WarningLevel>4</WarningLevel>
- <StartupObject/>
- </PropertyGroup>
- <PropertyGroup Condition=" '$(Configuration)|$(Platform)' == 'Debug|AnyCPU' ">
- <DebugSymbols>true</DebugSymbols>
- <DebugType>full</DebugType>
- <Optimize>false</Optimize>
- <OutputPath>bin\Debug\</OutputPath>
- <DefineConstants>DEBUG;TRACE</DefineConstants>
- <AllowUnsafeBlocks>false</AllowUnsafeBlocks>
- </PropertyGroup>
- <PropertyGroup Condition=" '$(Configuration)|$(Platform)' == 'Release|AnyCPU' ">
- <DebugSymbols>false</DebugSymbols>
- <Optimize>true</Optimize>
- <OutputPath>bin\Release\</OutputPath>
- <DefineConstants>TRACE</DefineConstants>
- <AllowUnsafeBlocks>false</AllowUnsafeBlocks>
- </PropertyGroup>
- <ItemGroup>
- <Reference Include="System"/>
- <Reference Include="System.Data"/>
- <Reference Include="System.Xml"/>
- </ItemGroup>
- <Import Project="$(MSBuildBinPath)\Microsoft.CSHARP.Targets"/>
- <ItemGroup>
- <Compile Include="OpenWire.Client\BrokerException.cs"/>
- <Compile Include="OpenWire.Client\Commands\ActiveMQBytesMessage.cs"/>
- <Compile Include="OpenWire.Client\Commands\ActiveMQDestination.cs"/>
- <Compile Include="OpenWire.Client\Commands\ActiveMQMapMessage.cs"/>
- <Compile Include="OpenWire.Client\Commands\ActiveMQMessage.cs"/>
- <Compile Include="OpenWire.Client\Commands\ActiveMQObjectMessage.cs"/>
- <Compile Include="OpenWire.Client\Commands\ActiveMQQueue.cs"/>
- <Compile Include="OpenWire.Client\Commands\ActiveMQStreamMessage.cs"/>
- <Compile Include="OpenWire.Client\Commands\ActiveMQTempDestination.cs"/>
- <Compile Include="OpenWire.Client\Commands\ActiveMQTempQueue.cs"/>
- <Compile Include="OpenWire.Client\Commands\ActiveMQTempTopic.cs"/>
- <Compile Include="OpenWire.Client\Commands\ActiveMQTextMessage.cs"/>
- <Compile Include="OpenWire.Client\Commands\ActiveMQTopic.cs"/>
- <Compile Include="OpenWire.Client\Commands\BaseCommand.cs"/>
- <Compile Include="OpenWire.Client\Commands\BrokerId.cs"/>
- <Compile Include="OpenWire.Client\Commands\BrokerInfo.cs"/>
- <Compile Include="OpenWire.Client\Commands\ConnectionError.cs"/>
- <Compile Include="OpenWire.Client\Commands\ConnectionId.cs"/>
- <Compile Include="OpenWire.Client\Commands\ConnectionInfo.cs"/>
- <Compile Include="OpenWire.Client\Commands\ConsumerId.cs"/>
- <Compile Include="OpenWire.Client\Commands\ConsumerInfo.cs"/>
- <Compile Include="OpenWire.Client\Commands\ControlCommand.cs"/>
- <Compile Include="OpenWire.Client\Commands\DataArrayResponse.cs"/>
- <Compile Include="OpenWire.Client\Commands\DataResponse.cs"/>
- <Compile Include="OpenWire.Client\Commands\DestinationInfo.cs"/>
- <Compile Include="OpenWire.Client\Commands\DiscoveryEvent.cs"/>
- <Compile Include="OpenWire.Client\Commands\ExceptionResponse.cs"/>
- <Compile Include="OpenWire.Client\Commands\FlushCommand.cs"/>
- <Compile Include="OpenWire.Client\Commands\IntegerResponse.cs"/>
- <Compile Include="OpenWire.Client\Commands\JournalQueueAck.cs"/>
- <Compile Include="OpenWire.Client\Commands\JournalTopicAck.cs"/>
- <Compile Include="OpenWire.Client\Commands\JournalTrace.cs"/>
- <Compile Include="OpenWire.Client\Commands\JournalTransaction.cs"/>
- <Compile Include="OpenWire.Client\Commands\KeepAliveInfo.cs"/>
- <Compile Include="OpenWire.Client\Commands\LocalTransactionId.cs"/>
- <Compile Include="OpenWire.Client\Commands\Message.cs"/>
- <Compile Include="OpenWire.Client\Commands\MessageAck.cs"/>
- <Compile Include="OpenWire.Client\Commands\MessageDispatch.cs"/>
- <Compile Include="OpenWire.Client\Commands\MessageDispatchNotification.cs"/>
- <Compile Include="OpenWire.Client\Commands\MessageId.cs"/>
- <Compile Include="OpenWire.Client\Commands\ProducerId.cs"/>
- <Compile Include="OpenWire.Client\Commands\ProducerInfo.cs"/>
- <Compile Include="OpenWire.Client\Commands\RemoveInfo.cs"/>
- <Compile Include="OpenWire.Client\Commands\RemoveSubscriptionInfo.cs"/>
- <Compile Include="OpenWire.Client\Commands\Response.cs"/>
- <Compile Include="OpenWire.Client\Commands\SessionId.cs"/>
- <Compile Include="OpenWire.Client\Commands\SessionInfo.cs"/>
- <Compile Include="OpenWire.Client\Commands\ShutdownInfo.cs"/>
- <Compile Include="OpenWire.Client\Commands\SubscriptionInfo.cs"/>
- <Compile Include="OpenWire.Client\Commands\TransactionId.cs"/>
- <Compile Include="OpenWire.Client\Commands\TransactionInfo.cs"/>
- <Compile Include="OpenWire.Client\Commands\WireFormatInfo.cs"/>
- <Compile Include="OpenWire.Client\Commands\XATransactionId.cs"/>
- <Compile Include="OpenWire.Client\Connection.cs"/>
- <Compile Include="OpenWire.Client\ConnectionClosedException.cs"/>
- <Compile Include="OpenWire.Client\ConnectionFactory.cs"/>
- <Compile Include="OpenWire.Client\ConsumerClosedException.cs"/>
- <Compile Include="OpenWire.Client\Core\AbstractCommand.cs"/>
- <Compile Include="OpenWire.Client\Core\BaseDataStreamMarshaller.cs"/>
- <Compile Include="OpenWire.Client\Core\BooleanStream.cs"/>
- <Compile Include="OpenWire.Client\Core\BrokerError.cs"/>
- <Compile Include="OpenWire.Client\Core\Command.cs"/>
- <Compile Include="OpenWire.Client\Core\DataStructure.cs"/>
- <Compile Include="OpenWire.Client\Core\DataStructureSupport.cs"/>
- <Compile Include="OpenWire.Client\Core\Dispatcher.cs"/>
- <Compile Include="OpenWire.Client\Core\FutureResponse.cs"/>
- <Compile Include="OpenWire.Client\Core\ISynchronization.cs"/>
- <Compile Include="OpenWire.Client\Core\ITransport.cs"/>
- <Compile Include="OpenWire.Client\Core\MarshallAware.cs"/>
- <Compile Include="OpenWire.Client\Core\MessagePropertyHelper.cs"/>
- <Compile Include="OpenWire.Client\Core\OpenWireFormat.cs"/>
- <Compile Include="OpenWire.Client\Core\PrimitiveMap.cs"/>
- <Compile Include="OpenWire.Client\Core\SocketTransport.cs"/>
- <Compile Include="OpenWire.Client\Core\TransactionContext.cs"/>
- <Compile Include="OpenWire.Client\DestinationFilter.cs"/>
- <Compile Include="OpenWire.Client\IBytesMessage.cs"/>
- <Compile Include="OpenWire.Client\IConnection.cs"/>
- <Compile Include="OpenWire.Client\IConnectionFactory.cs"/>
- <Compile Include="OpenWire.Client\IDestination.cs"/>
- <Compile Include="OpenWire.Client\IMapMessage.cs"/>
- <Compile Include="OpenWire.Client\IMessage.cs"/>
- <Compile Include="OpenWire.Client\IMessageConsumer.cs"/>
- <Compile Include="OpenWire.Client\IMessageProducer.cs"/>
- <Compile Include="OpenWire.Client\IO\ActiveMQBytesMessageMarshaller.cs"/>
- <Compile Include="OpenWire.Client\IO\ActiveMQDestinationMarshaller.cs"/>
- <Compile Include="OpenWire.Client\IO\ActiveMQMapMessageMarshaller.cs"/>
- <Compile Include="OpenWire.Client\IO\ActiveMQMessageMarshaller.cs"/>
- <Compile Include="OpenWire.Client\IO\ActiveMQObjectMessageMarshaller.cs"/>
- <Compile Include="OpenWire.Client\IO\ActiveMQQueueMarshaller.cs"/>
- <Compile Include="OpenWire.Client\IO\ActiveMQStreamMessageMarshaller.cs"/>
- <Compile Include="OpenWire.Client\IO\ActiveMQTempDestinationMarshaller.cs"/>
- <Compile Include="OpenWire.Client\IO\ActiveMQTempQueueMarshaller.cs"/>
- <Compile Include="OpenWire.Client\IO\ActiveMQTempTopicMarshaller.cs"/>
- <Compile Include="OpenWire.Client\IO\ActiveMQTextMessageMarshaller.cs"/>
- <Compile Include="OpenWire.Client\IO\ActiveMQTopicMarshaller.cs"/>
- <Compile Include="OpenWire.Client\IO\BaseCommandMarshaller.cs"/>
- <Compile Include="OpenWire.Client\IO\BrokerIdMarshaller.cs"/>
- <Compile Include="OpenWire.Client\IO\BrokerInfoMarshaller.cs"/>
- <Compile Include="OpenWire.Client\IO\ConnectionErrorMarshaller.cs"/>
- <Compile Include="OpenWire.Client\IO\ConnectionIdMarshaller.cs"/>
- <Compile Include="OpenWire.Client\IO\ConnectionInfoMarshaller.cs"/>
- <Compile Include="OpenWire.Client\IO\ConsumerIdMarshaller.cs"/>
- <Compile Include="OpenWire.Client\IO\ConsumerInfoMarshaller.cs"/>
- <Compile Include="OpenWire.Client\IO\ControlCommandMarshaller.cs"/>
- <Compile Include="OpenWire.Client\IO\DataArrayResponseMarshaller.cs"/>
- <Compile Include="OpenWire.Client\IO\DataResponseMarshaller.cs"/>
- <Compile Include="OpenWire.Client\IO\DataStructureSupportMarshaller.cs"/>
- <Compile Include="OpenWire.Client\IO\DestinationInfoMarshaller.cs"/>
- <Compile Include="OpenWire.Client\IO\DiscoveryEventMarshaller.cs"/>
- <Compile Include="OpenWire.Client\IO\ExceptionResponseMarshaller.cs"/>
- <Compile Include="OpenWire.Client\IO\FlushCommandMarshaller.cs"/>
- <Compile Include="OpenWire.Client\IO\IntegerResponseMarshaller.cs"/>
- <Compile Include="OpenWire.Client\IO\JournalQueueAckMarshaller.cs"/>
- <Compile Include="OpenWire.Client\IO\JournalTopicAckMarshaller.cs"/>
- <Compile Include="OpenWire.Client\IO\JournalTraceMarshaller.cs"/>
- <Compile Include="OpenWire.Client\IO\JournalTransactionMarshaller.cs"/>
- <Compile Include="OpenWire.Client\IO\KeepAliveInfoMarshaller.cs"/>
- <Compile Include="OpenWire.Client\IO\LocalTransactionIdMarshaller.cs"/>
- <Compile Include="OpenWire.Client\IO\MarshallerFactory.cs"/>
- <Compile Include="OpenWire.Client\IO\MessageAckMarshaller.cs"/>
- <Compile Include="OpenWire.Client\IO\MessageDispatchMarshaller.cs"/>
- <Compile Include="OpenWire.Client\IO\MessageDispatchNotificationMarshaller.cs"/>
- <Compile Include="OpenWire.Client\IO\MessageIdMarshaller.cs"/>
- <Compile Include="OpenWire.Client\IO\MessageMarshaller.cs"/>
- <Compile Include="OpenWire.Client\IO\ProducerIdMarshaller.cs"/>
- <Compile Include="OpenWire.Client\IO\ProducerInfoMarshaller.cs"/>
- <Compile Include="OpenWire.Client\IO\RemoveInfoMarshaller.cs"/>
- <Compile Include="OpenWire.Client\IO\RemoveSubscriptionInfoMarshaller.cs"/>
- <Compile Include="OpenWire.Client\IO\ResponseMarshaller.cs"/>
- <Compile Include="OpenWire.Client\IO\SessionIdMarshaller.cs"/>
- <Compile Include="OpenWire.Client\IO\SessionInfoMarshaller.cs"/>
- <Compile Include="OpenWire.Client\IO\ShutdownInfoMarshaller.cs"/>
- <Compile Include="OpenWire.Client\IO\SubscriptionInfoMarshaller.cs"/>
- <Compile Include="OpenWire.Client\IO\TransactionIdMarshaller.cs"/>
- <Compile Include="OpenWire.Client\IO\TransactionInfoMarshaller.cs"/>
- <Compile Include="OpenWire.Client\IO\WireFormatInfoMarshaller.cs"/>
- <Compile Include="OpenWire.Client\IO\XATransactionIdMarshaller.cs"/>
- <Compile Include="OpenWire.Client\IPrimitiveMap.cs"/>
- <Compile Include="OpenWire.Client\IQueue.cs"/>
- <Compile Include="OpenWire.Client\ISession.cs"/>
- <Compile Include="OpenWire.Client\IStartable.cs"/>
- <Compile Include="OpenWire.Client\ITemporaryQueue.cs"/>
- <Compile Include="OpenWire.Client\ITemporaryTopic.cs"/>
- <Compile Include="OpenWire.Client\ITextMessage.cs"/>
- <Compile Include="OpenWire.Client\ITopic.cs"/>
- <Compile Include="OpenWire.Client\MessageConsumer.cs"/>
- <Compile Include="OpenWire.Client\MessageProducer.cs"/>
- <Compile Include="OpenWire.Client\OpenWireException.cs"/>
- <Compile Include="OpenWire.Client\Session.cs"/>
- </ItemGroup>
-</Project>
+<Project xmlns="http://schemas.microsoft.com/developer/msbuild/2003" DefaultTargets="Build">
+ <PropertyGroup>
+ <Configuration Condition=" '$(Configuration)' == '' ">Debug</Configuration>
+ <Platform Condition=" '$(Platform)' == '' ">AnyCPU</Platform>
+ <ProductVersion>8.0.30703</ProductVersion>
+ <SchemaVersion>2.0</SchemaVersion>
+ <ProjectGuid>{F7BA9EF7-ADF7-40EF-9A9E-206649DBB10C}</ProjectGuid>
+ <OutputType>Library</OutputType>
+ <RootNamespace>src</RootNamespace>
+ <AssemblyName>src</AssemblyName>
+ <WarningLevel>4</WarningLevel>
+ <StartupObject/>
+ </PropertyGroup>
+ <PropertyGroup Condition=" '$(Configuration)|$(Platform)' == 'Debug|AnyCPU' ">
+ <DebugSymbols>true</DebugSymbols>
+ <DebugType>full</DebugType>
+ <Optimize>false</Optimize>
+ <OutputPath>bin\Debug\</OutputPath>
+ <DefineConstants>DEBUG;TRACE</DefineConstants>
+ <AllowUnsafeBlocks>false</AllowUnsafeBlocks>
+ </PropertyGroup>
+ <PropertyGroup Condition=" '$(Configuration)|$(Platform)' == 'Release|AnyCPU' ">
+ <DebugSymbols>false</DebugSymbols>
+ <Optimize>true</Optimize>
+ <OutputPath>bin\Release\</OutputPath>
+ <DefineConstants>TRACE</DefineConstants>
+ <AllowUnsafeBlocks>false</AllowUnsafeBlocks>
+ </PropertyGroup>
+ <ItemGroup>
+ <Reference Include="System"/>
+ <Reference Include="System.Data"/>
+ <Reference Include="System.Xml"/>
+ </ItemGroup>
+ <Import Project="$(MSBuildBinPath)\Microsoft.CSHARP.Targets"/>
+ <ItemGroup>
+ <Compile Include="ActiveMQ\BrokerException.cs"/>
+ <Compile Include="ActiveMQ\Connection.cs"/>
+ <Compile Include="ActiveMQ\ConnectionClosedException.cs"/>
+ <Compile Include="ActiveMQ\ConnectionFactory.cs"/>
+ <Compile Include="ActiveMQ\ConsumerClosedException.cs"/>
+ <Compile Include="ActiveMQ\DestinationFilter.cs"/>
+ <Compile Include="ActiveMQ\IBytesMessage.cs"/>
+ <Compile Include="ActiveMQ\IConnection.cs"/>
+ <Compile Include="ActiveMQ\IConnectionFactory.cs"/>
+ <Compile Include="ActiveMQ\IDestination.cs"/>
+ <Compile Include="ActiveMQ\IMapMessage.cs"/>
+ <Compile Include="ActiveMQ\IMessage.cs"/>
+ <Compile Include="ActiveMQ\IMessageConsumer.cs"/>
+ <Compile Include="ActiveMQ\IMessageProducer.cs"/>
+ <Compile Include="ActiveMQ\IPrimitiveMap.cs"/>
+ <Compile Include="ActiveMQ\IQueue.cs"/>
+ <Compile Include="ActiveMQ\ISession.cs"/>
+ <Compile Include="ActiveMQ\IStartable.cs"/>
+ <Compile Include="ActiveMQ\ITemporaryQueue.cs"/>
+ <Compile Include="ActiveMQ\ITemporaryTopic.cs"/>
+ <Compile Include="ActiveMQ\ITextMessage.cs"/>
+ <Compile Include="ActiveMQ\ITopic.cs"/>
+ <Compile Include="ActiveMQ\MessageConsumer.cs"/>
+ <Compile Include="ActiveMQ\MessageProducer.cs"/>
+ <Compile Include="ActiveMQ\OpenWire\AbstractCommand.cs"/>
+ <Compile Include="ActiveMQ\OpenWire\BaseDataStreamMarshaller.cs"/>
+ <Compile Include="ActiveMQ\OpenWire\BooleanStream.cs"/>
+ <Compile Include="ActiveMQ\OpenWire\BrokerError.cs"/>
+ <Compile Include="ActiveMQ\OpenWire\Command.cs"/>
+ <Compile Include="ActiveMQ\OpenWire\Commands\ActiveMQBytesMessage.cs"/>
+ <Compile Include="ActiveMQ\OpenWire\Commands\ActiveMQDestination.cs"/>
+ <Compile Include="ActiveMQ\OpenWire\Commands\ActiveMQMapMessage.cs"/>
+ <Compile Include="ActiveMQ\OpenWire\Commands\ActiveMQMessage.cs"/>
+ <Compile Include="ActiveMQ\OpenWire\Commands\ActiveMQObjectMessage.cs"/>
+ <Compile Include="ActiveMQ\OpenWire\Commands\ActiveMQQueue.cs"/>
+ <Compile Include="ActiveMQ\OpenWire\Commands\ActiveMQStreamMessage.cs"/>
+ <Compile Include="ActiveMQ\OpenWire\Commands\ActiveMQTempDestination.cs"/>
+ <Compile Include="ActiveMQ\OpenWire\Commands\ActiveMQTempQueue.cs"/>
+ <Compile Include="ActiveMQ\OpenWire\Commands\ActiveMQTempTopic.cs"/>
+ <Compile Include="ActiveMQ\OpenWire\Commands\ActiveMQTextMessage.cs"/>
+ <Compile Include="ActiveMQ\OpenWire\Commands\ActiveMQTopic.cs"/>
+ <Compile Include="ActiveMQ\OpenWire\Commands\BaseCommand.cs"/>
+ <Compile Include="ActiveMQ\OpenWire\Commands\BrokerId.cs"/>
+ <Compile Include="ActiveMQ\OpenWire\Commands\BrokerInfo.cs"/>
+ <Compile Include="ActiveMQ\OpenWire\Commands\ConnectionError.cs"/>
+ <Compile Include="ActiveMQ\OpenWire\Commands\ConnectionId.cs"/>
+ <Compile Include="ActiveMQ\OpenWire\Commands\ConnectionInfo.cs"/>
+ <Compile Include="ActiveMQ\OpenWire\Commands\ConsumerId.cs"/>
+ <Compile Include="ActiveMQ\OpenWire\Commands\ConsumerInfo.cs"/>
+ <Compile Include="ActiveMQ\OpenWire\Commands\ControlCommand.cs"/>
+ <Compile Include="ActiveMQ\OpenWire\Commands\DataArrayResponse.cs"/>
+ <Compile Include="ActiveMQ\OpenWire\Commands\DataResponse.cs"/>
+ <Compile Include="ActiveMQ\OpenWire\Commands\DestinationInfo.cs"/>
+ <Compile Include="ActiveMQ\OpenWire\Commands\DiscoveryEvent.cs"/>
+ <Compile Include="ActiveMQ\OpenWire\Commands\ExceptionResponse.cs"/>
+ <Compile Include="ActiveMQ\OpenWire\Commands\FlushCommand.cs"/>
+ <Compile Include="ActiveMQ\OpenWire\Commands\IntegerResponse.cs"/>
+ <Compile Include="ActiveMQ\OpenWire\Commands\JournalQueueAck.cs"/>
+ <Compile Include="ActiveMQ\OpenWire\Commands\JournalTopicAck.cs"/>
+ <Compile Include="ActiveMQ\OpenWire\Commands\JournalTrace.cs"/>
+ <Compile Include="ActiveMQ\OpenWire\Commands\JournalTransaction.cs"/>
+ <Compile Include="ActiveMQ\OpenWire\Commands\KeepAliveInfo.cs"/>
+ <Compile Include="ActiveMQ\OpenWire\Commands\LocalTransactionId.cs"/>
+ <Compile Include="ActiveMQ\OpenWire\Commands\Message.cs"/>
+ <Compile Include="ActiveMQ\OpenWire\Commands\MessageAck.cs"/>
+ <Compile Include="ActiveMQ\OpenWire\Commands\MessageDispatch.cs"/>
+ <Compile Include="ActiveMQ\OpenWire\Commands\MessageDispatchNotification.cs"/>
+ <Compile Include="ActiveMQ\OpenWire\Commands\MessageId.cs"/>
+ <Compile Include="ActiveMQ\OpenWire\Commands\ProducerId.cs"/>
+ <Compile Include="ActiveMQ\OpenWire\Commands\ProducerInfo.cs"/>
+ <Compile Include="ActiveMQ\OpenWire\Commands\RemoveInfo.cs"/>
+ <Compile Include="ActiveMQ\OpenWire\Commands\RemoveSubscriptionInfo.cs"/>
+ <Compile Include="ActiveMQ\OpenWire\Commands\Response.cs"/>
+ <Compile Include="ActiveMQ\OpenWire\Commands\SessionId.cs"/>
+ <Compile Include="ActiveMQ\OpenWire\Commands\SessionInfo.cs"/>
+ <Compile Include="ActiveMQ\OpenWire\Commands\ShutdownInfo.cs"/>
+ <Compile Include="ActiveMQ\OpenWire\Commands\SubscriptionInfo.cs"/>
+ <Compile Include="ActiveMQ\OpenWire\Commands\TransactionId.cs"/>
+ <Compile Include="ActiveMQ\OpenWire\Commands\TransactionInfo.cs"/>
+ <Compile Include="ActiveMQ\OpenWire\Commands\WireFormatInfo.cs"/>
+ <Compile Include="ActiveMQ\OpenWire\Commands\XATransactionId.cs"/>
+ <Compile Include="ActiveMQ\OpenWire\DataStructure.cs"/>
+ <Compile Include="ActiveMQ\OpenWire\DataStructureSupport.cs"/>
+ <Compile Include="ActiveMQ\OpenWire\Dispatcher.cs"/>
+ <Compile Include="ActiveMQ\OpenWire\FutureResponse.cs"/>
+ <Compile Include="ActiveMQ\OpenWire\ISynchronization.cs"/>
+ <Compile Include="ActiveMQ\OpenWire\ITransport.cs"/>
+ <Compile Include="ActiveMQ\OpenWire\MarshallAware.cs"/>
+ <Compile Include="ActiveMQ\OpenWire\MessagePropertyHelper.cs"/>
+ <Compile Include="ActiveMQ\OpenWire\OpenWireFormat.cs"/>
+ <Compile Include="ActiveMQ\OpenWire\PrimitiveMap.cs"/>
+ <Compile Include="ActiveMQ\OpenWire\SocketTransport.cs"/>
+ <Compile Include="ActiveMQ\OpenWire\TransactionContext.cs"/>
+ <Compile Include="ActiveMQ\OpenWire\V1\ActiveMQBytesMessageMarshaller.cs"/>
+ <Compile Include="ActiveMQ\OpenWire\V1\ActiveMQDestinationMarshaller.cs"/>
+ <Compile Include="ActiveMQ\OpenWire\V1\ActiveMQMapMessageMarshaller.cs"/>
+ <Compile Include="ActiveMQ\OpenWire\V1\ActiveMQMessageMarshaller.cs"/>
+ <Compile Include="ActiveMQ\OpenWire\V1\ActiveMQObjectMessageMarshaller.cs"/>
+ <Compile Include="ActiveMQ\OpenWire\V1\ActiveMQQueueMarshaller.cs"/>
+ <Compile Include="ActiveMQ\OpenWire\V1\ActiveMQStreamMessageMarshaller.cs"/>
+ <Compile Include="ActiveMQ\OpenWire\V1\ActiveMQTempDestinationMarshaller.cs"/>
+ <Compile Include="ActiveMQ\OpenWire\V1\ActiveMQTempQueueMarshaller.cs"/>
+ <Compile Include="ActiveMQ\OpenWire\V1\ActiveMQTempTopicMarshaller.cs"/>
+ <Compile Include="ActiveMQ\OpenWire\V1\ActiveMQTextMessageMarshaller.cs"/>
+ <Compile Include="ActiveMQ\OpenWire\V1\ActiveMQTopicMarshaller.cs"/>
+ <Compile Include="ActiveMQ\OpenWire\V1\BaseCommandMarshaller.cs"/>
+ <Compile Include="ActiveMQ\OpenWire\V1\BrokerIdMarshaller.cs"/>
+ <Compile Include="ActiveMQ\OpenWire\V1\BrokerInfoMarshaller.cs"/>
+ <Compile Include="ActiveMQ\OpenWire\V1\ConnectionErrorMarshaller.cs"/>
+ <Compile Include="ActiveMQ\OpenWire\V1\ConnectionIdMarshaller.cs"/>
+ <Compile Include="ActiveMQ\OpenWire\V1\ConnectionInfoMarshaller.cs"/>
+ <Compile Include="ActiveMQ\OpenWire\V1\ConsumerIdMarshaller.cs"/>
+ <Compile Include="ActiveMQ\OpenWire\V1\ConsumerInfoMarshaller.cs"/>
+ <Compile Include="ActiveMQ\OpenWire\V1\ControlCommandMarshaller.cs"/>
+ <Compile Include="ActiveMQ\OpenWire\V1\DataArrayResponseMarshaller.cs"/>
+ <Compile Include="ActiveMQ\OpenWire\V1\DataResponseMarshaller.cs"/>
+ <Compile Include="ActiveMQ\OpenWire\V1\DataStructureSupportMarshaller.cs"/>
+ <Compile Include="ActiveMQ\OpenWire\V1\DestinationInfoMarshaller.cs"/>
+ <Compile Include="ActiveMQ\OpenWire\V1\DiscoveryEventMarshaller.cs"/>
+ <Compile Include="ActiveMQ\OpenWire\V1\ExceptionResponseMarshaller.cs"/>
+ <Compile Include="ActiveMQ\OpenWire\V1\FlushCommandMarshaller.cs"/>
+ <Compile Include="ActiveMQ\OpenWire\V1\IntegerResponseMarshaller.cs"/>
+ <Compile Include="ActiveMQ\OpenWire\V1\JournalQueueAckMarshaller.cs"/>
+ <Compile Include="ActiveMQ\OpenWire\V1\JournalTopicAckMarshaller.cs"/>
+ <Compile Include="ActiveMQ\OpenWire\V1\JournalTraceMarshaller.cs"/>
+ <Compile Include="ActiveMQ\OpenWire\V1\JournalTransactionMarshaller.cs"/>
+ <Compile Include="ActiveMQ\OpenWire\V1\KeepAliveInfoMarshaller.cs"/>
+ <Compile Include="ActiveMQ\OpenWire\V1\LocalTransactionIdMarshaller.cs"/>
+ <Compile Include="ActiveMQ\OpenWire\V1\MarshallerFactory.cs"/>
+ <Compile Include="ActiveMQ\OpenWire\V1\MessageAckMarshaller.cs"/>
+ <Compile Include="ActiveMQ\OpenWire\V1\MessageDispatchMarshaller.cs"/>
+ <Compile Include="ActiveMQ\OpenWire\V1\MessageDispatchNotificationMarshaller.cs"/>
+ <Compile Include="ActiveMQ\OpenWire\V1\MessageIdMarshaller.cs"/>
+ <Compile Include="ActiveMQ\OpenWire\V1\MessageMarshaller.cs"/>
+ <Compile Include="ActiveMQ\OpenWire\V1\ProducerIdMarshaller.cs"/>
+ <Compile Include="ActiveMQ\OpenWire\V1\ProducerInfoMarshaller.cs"/>
+ <Compile Include="ActiveMQ\OpenWire\V1\RemoveInfoMarshaller.cs"/>
+ <Compile Include="ActiveMQ\OpenWire\V1\RemoveSubscriptionInfoMarshaller.cs"/>
+ <Compile Include="ActiveMQ\OpenWire\V1\ResponseMarshaller.cs"/>
+ <Compile Include="ActiveMQ\OpenWire\V1\SessionIdMarshaller.cs"/>
+ <Compile Include="ActiveMQ\OpenWire\V1\SessionInfoMarshaller.cs"/>
+ <Compile Include="ActiveMQ\OpenWire\V1\ShutdownInfoMarshaller.cs"/>
+ <Compile Include="ActiveMQ\OpenWire\V1\SubscriptionInfoMarshaller.cs"/>
+ <Compile Include="ActiveMQ\OpenWire\V1\TransactionIdMarshaller.cs"/>
+ <Compile Include="ActiveMQ\OpenWire\V1\TransactionInfoMarshaller.cs"/>
+ <Compile Include="ActiveMQ\OpenWire\V1\WireFormatInfoMarshaller.cs"/>
+ <Compile Include="ActiveMQ\OpenWire\V1\XATransactionIdMarshaller.cs"/>
+ <Compile Include="ActiveMQ\OpenWireException.cs"/>
+ <Compile Include="ActiveMQ\Session.cs"/>
+ </ItemGroup>
+</Project>
Modified: incubator/activemq/trunk/openwire-dotnet/tests/ActiveMQ/AsyncConsumeTest.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/tests/ActiveMQ/AsyncConsumeTest.cs?rev=383072&r1=383071&r2=383072&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/tests/ActiveMQ/AsyncConsumeTest.cs (original)
+++ incubator/activemq/trunk/openwire-dotnet/tests/ActiveMQ/AsyncConsumeTest.cs Sat Mar 4 00:19:09 2006
@@ -1,77 +1,91 @@
-using System;
-using System.IO;
-using System.Threading;
-
-using NUnit.Framework;
-
-using OpenWire.Client;
-using OpenWire.Client.Core;
-namespace OpenWire.Client
-{
- [TestFixture]
- public class AsyncConsumeTest : TestSupport
- {
- protected Object semaphore = new Object();
- protected bool received;
-
- [Test]
- public void TestAsynchronousConsume()
- {
- IConnectionFactory factory = new ConnectionFactory("localhost", 61616);
- Assert.IsTrue(factory != null, "no factory created");
-
- using (IConnection connection = factory.CreateConnection())
- {
- Assert.IsTrue(connection != null, "no connection created");
- Console.WriteLine("Connected to ActiveMQ!");
-
- ISession session = connection.CreateSession();
- IDestination destination = CreateDestination(session);
- Assert.IsTrue(destination != null, "No queue available!");
-
- // lets create an async consumer
- // START SNIPPET: demo
- IMessageConsumer consumer = session.CreateConsumer(destination);
- consumer.Listener += new MessageListener(OnMessage);
- // END SNIPPET: demo
-
-
- // now lets send a message
- session = connection.CreateSession();
- IMessageProducer producer = session.CreateProducer(destination);
- IMessage request = CreateMessage(session);
- request.JMSCorrelationID = "abc";
- request.JMSType = "Test";
- producer.Send(request);
-
-
- WaitForMessageToArrive();
- }
-
- }
-
- protected void OnMessage(IMessage message)
- {
- Console.WriteLine("Received message: " + message);
- lock (semaphore)
- {
- received = true;
- Monitor.PulseAll(semaphore);
- }
-
- }
-
- protected void WaitForMessageToArrive()
- {
- lock (semaphore)
- {
- if (!received)
- {
- Monitor.Wait(semaphore, 10000);
- }
- }
- Assert.AreEqual(true, received, "Should have received a message by now!");
- }
-
- }
-}
+/*
+ * Copyright 2006 The Apache Software Foundation or its licensors, as
+ * applicable.
+ *
+ * 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.
+*/
+using System;
+using System.IO;
+using System.Threading;
+
+using NUnit.Framework;
+
+namespace ActiveMQ
+{
+ [TestFixture]
+ public class AsyncConsumeTest : TestSupport
+ {
+ protected Object semaphore = new Object();
+ protected bool received;
+
+ [Test]
+ public void TestAsynchronousConsume()
+ {
+ IConnectionFactory factory = new ConnectionFactory("localhost", 61616);
+ Assert.IsTrue(factory != null, "no factory created");
+
+ using (IConnection connection = factory.CreateConnection())
+ {
+ Assert.IsTrue(connection != null, "no connection created");
+ Console.WriteLine("Connected to ActiveMQ!");
+
+ ISession session = connection.CreateSession();
+ IDestination destination = CreateDestination(session);
+ Assert.IsTrue(destination != null, "No queue available!");
+
+ // lets create an async consumer
+ // START SNIPPET: demo
+ IMessageConsumer consumer = session.CreateConsumer(destination);
+ consumer.Listener += new MessageListener(OnMessage);
+ // END SNIPPET: demo
+
+
+ // now lets send a message
+ session = connection.CreateSession();
+ IMessageProducer producer = session.CreateProducer(destination);
+ IMessage request = CreateMessage(session);
+ request.JMSCorrelationID = "abc";
+ request.JMSType = "Test";
+ producer.Send(request);
+
+
+ WaitForMessageToArrive();
+ }
+
+ }
+
+ protected void OnMessage(IMessage message)
+ {
+ Console.WriteLine("Received message: " + message);
+ lock (semaphore)
+ {
+ received = true;
+ Monitor.PulseAll(semaphore);
+ }
+
+ }
+
+ protected void WaitForMessageToArrive()
+ {
+ lock (semaphore)
+ {
+ if (!received)
+ {
+ Monitor.Wait(semaphore, 10000);
+ }
+ }
+ Assert.AreEqual(true, received, "Should have received a message by now!");
+ }
+
+ }
+}
Modified: incubator/activemq/trunk/openwire-dotnet/tests/ActiveMQ/BadConsumeTest.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/tests/ActiveMQ/BadConsumeTest.cs?rev=383072&r1=383071&r2=383072&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/tests/ActiveMQ/BadConsumeTest.cs (original)
+++ incubator/activemq/trunk/openwire-dotnet/tests/ActiveMQ/BadConsumeTest.cs Sat Mar 4 00:19:09 2006
@@ -1,33 +1,49 @@
-using NUnit.Framework;
-using System;
-
-namespace OpenWire.Client
-{
- [TestFixture]
- public class BadConsumeTest : TestSupport
- {
- [Test]
- public void TestBadConsumeOperationToTestExceptions()
- {
- IConnectionFactory factory = new ConnectionFactory("localhost", 61616);
- using (IConnection connection = factory.CreateConnection())
- {
- ISession session = connection.CreateSession();
-
- try
- {
- IMessageConsumer consumer = session.CreateConsumer(null);
- Console.WriteLine("Created consumer: " + consumer);
-
- Assert.Fail("Should have thrown an exception!");
- }
- catch (BrokerException e)
- {
- Console.WriteLine("Caught expected exception: " + e);
- Console.WriteLine("Stack: " + e.StackTrace);
- Console.WriteLine("Java Stack: " + e.JavaStackTrace);
- }
- }
- }
- }
-}
+/*
+ * Copyright 2006 The Apache Software Foundation or its licensors, as
+ * applicable.
+ *
+ * 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.
+*/
+using NUnit.Framework;
+using System;
+
+namespace ActiveMQ
+{
+ [TestFixture]
+ public class BadConsumeTest : TestSupport
+ {
+ [Test]
+ public void TestBadConsumeOperationToTestExceptions()
+ {
+ IConnectionFactory factory = new ConnectionFactory("localhost", 61616);
+ using (IConnection connection = factory.CreateConnection())
+ {
+ ISession session = connection.CreateSession();
+
+ try
+ {
+ IMessageConsumer consumer = session.CreateConsumer(null);
+ Console.WriteLine("Created consumer: " + consumer);
+
+ Assert.Fail("Should have thrown an exception!");
+ }
+ catch (BrokerException e)
+ {
+ Console.WriteLine("Caught expected exception: " + e);
+ Console.WriteLine("Stack: " + e.StackTrace);
+ Console.WriteLine("Java Stack: " + e.JavaStackTrace);
+ }
+ }
+ }
+ }
+}
Modified: incubator/activemq/trunk/openwire-dotnet/tests/ActiveMQ/BytesMessageTest.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/tests/ActiveMQ/BytesMessageTest.cs?rev=383072&r1=383071&r2=383072&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/tests/ActiveMQ/BytesMessageTest.cs (original)
+++ incubator/activemq/trunk/openwire-dotnet/tests/ActiveMQ/BytesMessageTest.cs Sat Mar 4 00:19:09 2006
@@ -1,58 +1,55 @@
-/*
- * Copyright 2006 The Apache Software Foundation or its licensors, as
- * applicable.
- *
- * 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.
-*/
-using System;
-using System.IO;
-
-using NUnit.Framework;
-
-using OpenWire.Client;
-using OpenWire.Client.Core;
-
-namespace OpenWire.Client
-{
- [ TestFixture ]
- public class BytesMessageTest : TestSupport
- {
- byte[] expected = {1, 2, 3, 4, 5, 6, 7, 8};
-
- [ Test ]
- public override void SendAndSyncReceive()
- {
- base.SendAndSyncReceive();
- }
-
- protected override IMessage CreateMessage(ISession session)
- {
- IBytesMessage request = session.CreateBytesMessage(expected);
- return request;
- }
-
- protected override void AssertValidMessage(IMessage message)
- {
- Assert.IsTrue(message is IBytesMessage, "Did not receive a IBytesMessage: " + message);
-
- Console.WriteLine("Received IBytesMessage: " + message);
-
- IBytesMessage bytesMessage = (IBytesMessage) message;
- byte[] actual = bytesMessage.Content;
- Console.WriteLine("Received message with content: " + actual);
- Assert.AreEqual(expected, actual, "the message content");
- }
-
- }
-}
-
+/*
+ * Copyright 2006 The Apache Software Foundation or its licensors, as
+ * applicable.
+ *
+ * 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.
+*/
+using System;
+using System.IO;
+
+using NUnit.Framework;
+
+namespace ActiveMQ
+{
+ [ TestFixture ]
+ public class BytesMessageTest : TestSupport
+ {
+ byte[] expected = {1, 2, 3, 4, 5, 6, 7, 8};
+
+ [ Test ]
+ public override void SendAndSyncReceive()
+ {
+ base.SendAndSyncReceive();
+ }
+
+ protected override IMessage CreateMessage(ISession session)
+ {
+ IBytesMessage request = session.CreateBytesMessage(expected);
+ return request;
+ }
+
+ protected override void AssertValidMessage(IMessage message)
+ {
+ Assert.IsTrue(message is IBytesMessage, "Did not receive a IBytesMessage: " + message);
+
+ Console.WriteLine("Received IBytesMessage: " + message);
+
+ IBytesMessage bytesMessage = (IBytesMessage) message;
+ byte[] actual = bytesMessage.Content;
+ Console.WriteLine("Received message with content: " + actual);
+ Assert.AreEqual(expected, actual, "the message content");
+ }
+
+ }
+}
+
Modified: incubator/activemq/trunk/openwire-dotnet/tests/ActiveMQ/ClientTest.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/tests/ActiveMQ/ClientTest.cs?rev=383072&r1=383071&r2=383072&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/tests/ActiveMQ/ClientTest.cs (original)
+++ incubator/activemq/trunk/openwire-dotnet/tests/ActiveMQ/ClientTest.cs Sat Mar 4 00:19:09 2006
@@ -19,10 +19,7 @@
using NUnit.Framework;
-using OpenWire.Client;
-using OpenWire.Client.Core;
-
-namespace OpenWire.Client
+namespace ActiveMQ
{
[ TestFixture ]
public class ClientTest : TestSupport
Modified: incubator/activemq/trunk/openwire-dotnet/tests/ActiveMQ/CommandTest.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/tests/ActiveMQ/CommandTest.cs?rev=383072&r1=383071&r2=383072&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/tests/ActiveMQ/CommandTest.cs (original)
+++ incubator/activemq/trunk/openwire-dotnet/tests/ActiveMQ/CommandTest.cs Sat Mar 4 00:19:09 2006
@@ -1,61 +1,63 @@
-/*
- * Copyright 2006 The Apache Software Foundation or its licensors, as
- * applicable.
- *
- * 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.
- */
-using NUnit.Framework;
-using OpenWire.Client.Commands;
-using System.Collections;
-
-namespace OpenWire.Client
-{
- [TestFixture]
- public class CommandTest
- {
-
- [Test]
- public void TestCommand()
- {
- ConsumerId value1 = new ConsumerId();
- value1.ConnectionId = "abc";
- value1.SessionId = 123;
- value1.Value = 456;
-
- ConsumerId value2 = new ConsumerId();
- value2.ConnectionId = "abc";
- value2.SessionId = 123;
- value2.Value = 456;
-
- ConsumerId value3 = new ConsumerId();
- value3.ConnectionId = "abc";
- value3.SessionId = 123;
- value3.Value = 457;
-
- Assert.AreEqual(value1, value2, "value1 and value2 should be equal");
- Assert.AreEqual(value1.GetHashCode(), value2.GetHashCode(), "value1 and value2 hash codes should be equal");
-
- Assert.IsTrue(!value1.Equals(value3), "value1 and value3 should not be equal");
- Assert.IsTrue(!value3.Equals(value2), "value3 and value2 should not be equal");
-
- // now lets test an IDictionary
- IDictionary dictionary = new Hashtable();
- dictionary[value1] = value3;
-
- // now lets lookup with a copy
- object actual = dictionary[value2];
-
- Assert.AreEqual(value3, actual, "Should have found item in Map using value2 as a key");
- }
- }
-}
+/*
+ * Copyright 2006 The Apache Software Foundation or its licensors, as
+ * applicable.
+ *
+ * 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.
+ */
+using NUnit.Framework;
+using System.Collections;
+
+using ActiveMQ.OpenWire;
+using ActiveMQ.OpenWire.Commands;
+
+namespace ActiveMQ
+{
+ [TestFixture]
+ public class CommandTest
+ {
+
+ [Test]
+ public void TestCommand()
+ {
+ ConsumerId value1 = new ConsumerId();
+ value1.ConnectionId = "abc";
+ value1.SessionId = 123;
+ value1.Value = 456;
+
+ ConsumerId value2 = new ConsumerId();
+ value2.ConnectionId = "abc";
+ value2.SessionId = 123;
+ value2.Value = 456;
+
+ ConsumerId value3 = new ConsumerId();
+ value3.ConnectionId = "abc";
+ value3.SessionId = 123;
+ value3.Value = 457;
+
+ Assert.AreEqual(value1, value2, "value1 and value2 should be equal");
+ Assert.AreEqual(value1.GetHashCode(), value2.GetHashCode(), "value1 and value2 hash codes should be equal");
+
+ Assert.IsTrue(!value1.Equals(value3), "value1 and value3 should not be equal");
+ Assert.IsTrue(!value3.Equals(value2), "value3 and value2 should not be equal");
+
+ // now lets test an IDictionary
+ IDictionary dictionary = new Hashtable();
+ dictionary[value1] = value3;
+
+ // now lets lookup with a copy
+ object actual = dictionary[value2];
+
+ Assert.AreEqual(value3, actual, "Should have found item in Map using value2 as a key");
+ }
+ }
+}
Modified: incubator/activemq/trunk/openwire-dotnet/tests/ActiveMQ/ConsumerTest.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/tests/ActiveMQ/ConsumerTest.cs?rev=383072&r1=383071&r2=383072&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/tests/ActiveMQ/ConsumerTest.cs (original)
+++ incubator/activemq/trunk/openwire-dotnet/tests/ActiveMQ/ConsumerTest.cs Sat Mar 4 00:19:09 2006
@@ -1,92 +1,89 @@
-/*
- * Copyright 2006 The Apache Software Foundation or its licensors, as
- * applicable.
- *
- * 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.
- */
-using System;
-using System.IO;
-
-using NUnit.Framework;
-
-using OpenWire.Client;
-using OpenWire.Client.Core;
-
-namespace OpenWire.Client
-{
- [TestFixture]
- public class ConsumerTest : TestSupport
- {
- IConnectionFactory factory;
- IConnection connection;
- IDestination destination;
-
- [SetUp]
- protected void SetUp()
- {
- factory = new ConnectionFactory("localhost", 61616);
- connection = factory.CreateConnection();
- }
-
- [TearDown]
- protected void TearDown()
- {
- connection.Dispose();
- }
-
- [Test]
- [Ignore("Not fully implemented yet.")]
- public void testDurableConsumerSelectorChange()
- {
-
- // Receive a message with the JMS API
- connection.ClientId="test";
- connection.Start();
-
- ISession session = connection.CreateSession(AcknowledgementMode.AutoAcknowledge);
- destination = session.GetTopic("foo");
- IMessageProducer producer = session.CreateProducer(destination);
- producer.Persistent = true;
- IMessageConsumer consumer = session.CreateDurableConsumer((ITopic)destination, "test", "color='red'", false);
-
- // Send the messages
- ITextMessage message = session.CreateTextMessage("1st");
- //message.SetStringProperty("color", "red");
- producer.Send(message);
-
- IMessage m = consumer.Receive(1000);
- Assert.IsNotNull(m);
- Assert.AreEqual("1st", ((ITextMessage)m).Text );
-
- // Change the subscription.
- consumer.Dispose();
- consumer = session.CreateDurableConsumer((ITopic)destination, "test", "color='blue'", false);
-
- message = session.CreateTextMessage("2nd");
- // message.setStringProperty("color", "red");
- producer.Send(message);
- message = session.CreateTextMessage("3rd");
- // message.setStringProperty("color", "blue");
- producer.Send(message);
-
- // Selector should skip the 2nd message.
- m = consumer.Receive(1000);
- Assert.IsNotNull(m);
- Assert.AreEqual("3rd", ((ITextMessage)m).Text);
-
- Assert.IsNull(consumer.ReceiveNoWait());
- }
-
- }
-}
-
+/*
+ * Copyright 2006 The Apache Software Foundation or its licensors, as
+ * applicable.
+ *
+ * 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.
+ */
+using System;
+using System.IO;
+
+using NUnit.Framework;
+
+namespace ActiveMQ
+{
+ [TestFixture]
+ public class ConsumerTest : TestSupport
+ {
+ IConnectionFactory factory;
+ IConnection connection;
+ IDestination destination;
+
+ [SetUp]
+ protected void SetUp()
+ {
+ factory = new ConnectionFactory("localhost", 61616);
+ connection = factory.CreateConnection();
+ }
+
+ [TearDown]
+ protected void TearDown()
+ {
+ connection.Dispose();
+ }
+
+ [Test]
+ [Ignore("Not fully implemented yet.")]
+ public void testDurableConsumerSelectorChange()
+ {
+
+ // Receive a message with the JMS API
+ connection.ClientId="test";
+ connection.Start();
+
+ ISession session = connection.CreateSession(AcknowledgementMode.AutoAcknowledge);
+ destination = session.GetTopic("foo");
+ IMessageProducer producer = session.CreateProducer(destination);
+ producer.Persistent = true;
+ IMessageConsumer consumer = session.CreateDurableConsumer((ITopic)destination, "test", "color='red'", false);
+
+ // Send the messages
+ ITextMessage message = session.CreateTextMessage("1st");
+ //message.SetStringProperty("color", "red");
+ producer.Send(message);
+
+ IMessage m = consumer.Receive(1000);
+ Assert.IsNotNull(m);
+ Assert.AreEqual("1st", ((ITextMessage)m).Text );
+
+ // Change the subscription.
+ consumer.Dispose();
+ consumer = session.CreateDurableConsumer((ITopic)destination, "test", "color='blue'", false);
+
+ message = session.CreateTextMessage("2nd");
+ // message.setStringProperty("color", "red");
+ producer.Send(message);
+ message = session.CreateTextMessage("3rd");
+ // message.setStringProperty("color", "blue");
+ producer.Send(message);
+
+ // Selector should skip the 2nd message.
+ m = consumer.Receive(1000);
+ Assert.IsNotNull(m);
+ Assert.AreEqual("3rd", ((ITextMessage)m).Text);
+
+ Assert.IsNull(consumer.ReceiveNoWait());
+ }
+
+ }
+}
+
Modified: incubator/activemq/trunk/openwire-dotnet/tests/ActiveMQ/EndianTest.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/tests/ActiveMQ/EndianTest.cs?rev=383072&r1=383071&r2=383072&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/tests/ActiveMQ/EndianTest.cs (original)
+++ incubator/activemq/trunk/openwire-dotnet/tests/ActiveMQ/EndianTest.cs Sat Mar 4 00:19:09 2006
@@ -1,76 +1,78 @@
-/*
- * Copyright 2006 The Apache Software Foundation or its licensors, as
- * applicable.
- *
- * 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.
- */
-using NUnit.Framework;
-using OpenWire.Client.Core;
-using System;
-
-namespace openwire_dotnet
-{
- [TestFixture]
- public class EndianTest
- {
-
- [Test]
- public void TestLongEndian()
- {
- long value = 0x0102030405060708L;
-
- long newValue = BaseDataStreamMarshaller.SwitchEndian(value);
-
- Console.WriteLine("New value: " + newValue);
-
- Assert.AreEqual(0x0807060504030201L, newValue);
-
- long actual = BaseDataStreamMarshaller.SwitchEndian(newValue);
-
- Assert.AreEqual(value, actual);
- }
-
- [Test]
- public void TestIntEndian()
- {
- int value = 0x12345678;
-
- int newValue = BaseDataStreamMarshaller.SwitchEndian(value);
-
- Console.WriteLine("New value: " + newValue);
-
- Assert.AreEqual(0x78563412, newValue);
-
- int actual = BaseDataStreamMarshaller.SwitchEndian(newValue);
-
- Assert.AreEqual(value, actual);
- }
- [Test]
- public void TestShortEndian()
- {
- short value = 0x1234;
-
- short newValue = BaseDataStreamMarshaller.SwitchEndian(value);
-
- Console.WriteLine("New value: " + newValue);
-
- Assert.AreEqual(0x3412, newValue);
-
- short actual = BaseDataStreamMarshaller.SwitchEndian(newValue);
-
- Assert.AreEqual(value, actual);
- }
- }
-}
-
-
+/*
+ * Copyright 2006 The Apache Software Foundation or its licensors, as
+ * applicable.
+ *
+ * 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.
+ */
+using NUnit.Framework;
+using System;
+
+using ActiveMQ.OpenWire;
+using ActiveMQ.OpenWire.Commands;
+
+namespace ActiveMQ
+{
+ [TestFixture]
+ public class EndianTest
+ {
+
+ [Test]
+ public void TestLongEndian()
+ {
+ long value = 0x0102030405060708L;
+
+ long newValue = BaseDataStreamMarshaller.SwitchEndian(value);
+
+ Console.WriteLine("New value: " + newValue);
+
+ Assert.AreEqual(0x0807060504030201L, newValue);
+
+ long actual = BaseDataStreamMarshaller.SwitchEndian(newValue);
+
+ Assert.AreEqual(value, actual);
+ }
+
+ [Test]
+ public void TestIntEndian()
+ {
+ int value = 0x12345678;
+
+ int newValue = BaseDataStreamMarshaller.SwitchEndian(value);
+
+ Console.WriteLine("New value: " + newValue);
+
+ Assert.AreEqual(0x78563412, newValue);
+
+ int actual = BaseDataStreamMarshaller.SwitchEndian(newValue);
+
+ Assert.AreEqual(value, actual);
+ }
+ [Test]
+ public void TestShortEndian()
+ {
+ short value = 0x1234;
+
+ short newValue = BaseDataStreamMarshaller.SwitchEndian(value);
+
+ Console.WriteLine("New value: " + newValue);
+
+ Assert.AreEqual(0x3412, newValue);
+
+ short actual = BaseDataStreamMarshaller.SwitchEndian(newValue);
+
+ Assert.AreEqual(value, actual);
+ }
+ }
+}
+
+
Modified: incubator/activemq/trunk/openwire-dotnet/tests/ActiveMQ/JMSPropertyTest.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/tests/ActiveMQ/JMSPropertyTest.cs?rev=383072&r1=383071&r2=383072&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/tests/ActiveMQ/JMSPropertyTest.cs (original)
+++ incubator/activemq/trunk/openwire-dotnet/tests/ActiveMQ/JMSPropertyTest.cs Sat Mar 4 00:19:09 2006
@@ -1,127 +1,124 @@
-/*
- * Copyright 2006 The Apache Software Foundation or its licensors, as
- * applicable.
- *
- * 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.
- */
-using System;
-using System.IO;
-
-using NUnit.Framework;
-
-using OpenWire.Client;
-using OpenWire.Client.Core;
-
-namespace OpenWire.Client
-{
- [ TestFixture ]
- public class JMSPropertyTest : TestSupport
- {
- // standard JMS properties
- string expectedText = "Hey this works!";
- string correlationID = "abc";
- ITemporaryQueue replyTo;
- bool persistent = true;
- byte priority = 5;
- String type = "FooType";
- String groupID = "MyGroup";
- int groupSeq = 1;
-
- // custom properties
- string customText = "Cheese";
- bool custom1 = true;
- byte custom2 = 12;
- short custom3 = 0x1234;
- int custom4 = 0x12345678;
- long custom5 = 0x1234567812345678;
- char custom6 = 'J';
-
- [ Test ]
- public override void SendAndSyncReceive()
- {
- base.SendAndSyncReceive();
- }
-
- protected override IMessage CreateMessage(ISession session)
- {
- ITextMessage message = session.CreateTextMessage(expectedText);
- replyTo = session.CreateTemporaryQueue();
-
- // lets set the headers
- message.JMSCorrelationID = correlationID;
- message.JMSReplyTo = replyTo;
- message.JMSPersistent = persistent;
- message.JMSPriority = priority;
- message.JMSType = type;
- message.JMSXGroupID = groupID;
- message.JMSXGroupSeq = groupSeq;
-
- // lets set the custom headers
- message.Properties["customText"] = customText;
- message.Properties["custom1"] = custom1;
- message.Properties["custom2"] = custom2;
- message.Properties["custom3"] = custom3;
- message.Properties["custom4"] = custom4;
- message.Properties["custom5"] = custom5;
- message.Properties["custom6"] = custom6;
-
- return message;
- }
-
- protected override void AssertValidMessage(IMessage message)
- {
- Assert.IsTrue(message is ITextMessage, "Did not receive a ITextMessage!");
-
- Console.WriteLine("Received Message: " + message);
-
- ITextMessage textMessage = (ITextMessage) message;
- String text = textMessage.Text;
- Assert.AreEqual(expectedText, text, "the message text");
-
- // compare standard JMS headers
- Assert.AreEqual(correlationID, message.JMSCorrelationID, "JMSCorrelationID");
- Assert.AreEqual(replyTo, message.JMSReplyTo, "JMSReplyTo");
- Assert.AreEqual(persistent, message.JMSPersistent, "JMSPersistent");
- Assert.AreEqual(priority, message.JMSPriority, "JMSPriority");
- Assert.AreEqual(type, message.JMSType, "JMSType");
- Assert.AreEqual(groupID, message.JMSXGroupID, "JMSXGroupID");
- Assert.AreEqual(groupSeq, message.JMSXGroupSeq, "JMSXGroupSeq");
-
- // compare custom headers
- Assert.AreEqual(customText, message.Properties["customText"], "customText");
- Assert.AreEqual(custom1, message.Properties["custom1"], "custom1");
- Assert.AreEqual(custom2, message.Properties["custom2"], "custom2");
- Assert.AreEqual(custom3, message.Properties["custom3"], "custom3");
- Assert.AreEqual(custom4, message.Properties["custom4"], "custom4");
- // TODO
- Assert.AreEqual(custom5, message.Properties["custom5"], "custom5");
- Assert.AreEqual(custom6, message.Properties["custom6"], "custom6");
-
- Assert.AreEqual(custom1, message.Properties.GetBool("custom1"), "custom1");
- Assert.AreEqual(custom2, message.Properties.GetByte("custom2"), "custom2");
- Assert.AreEqual(custom3, message.Properties.GetShort("custom3"), "custom3");
- Assert.AreEqual(custom4, message.Properties.GetInt("custom4"), "custom4");
- Assert.AreEqual(custom5, message.Properties.GetLong("custom5"), "custom5");
- Assert.AreEqual(custom6, message.Properties.GetChar("custom6"), "custom6");
-
- // lets now look at some standard JMS headers
- Console.WriteLine("JMSExpiration: " + message.JMSExpiration);
- Console.WriteLine("JMSMessageId: " + message.JMSMessageId);
- Console.WriteLine("JMSRedelivered: " + message.JMSRedelivered);
- Console.WriteLine("JMSTimestamp: " + message.JMSTimestamp);
- Console.WriteLine("JMSXDeliveryCount: " + message.JMSXDeliveryCount);
- Console.WriteLine("JMSXProducerTXID: " + message.JMSXProducerTXID);
- }
- }
-}
-
+/*
+ * Copyright 2006 The Apache Software Foundation or its licensors, as
+ * applicable.
+ *
+ * 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.
+ */
+using System;
+using System.IO;
+
+using NUnit.Framework;
+
+namespace ActiveMQ
+{
+ [ TestFixture ]
+ public class JMSPropertyTest : TestSupport
+ {
+ // standard JMS properties
+ string expectedText = "Hey this works!";
+ string correlationID = "abc";
+ ITemporaryQueue replyTo;
+ bool persistent = true;
+ byte priority = 5;
+ String type = "FooType";
+ String groupID = "MyGroup";
+ int groupSeq = 1;
+
+ // custom properties
+ string customText = "Cheese";
+ bool custom1 = true;
+ byte custom2 = 12;
+ short custom3 = 0x1234;
+ int custom4 = 0x12345678;
+ long custom5 = 0x1234567812345678;
+ char custom6 = 'J';
+
+ [ Test ]
+ public override void SendAndSyncReceive()
+ {
+ base.SendAndSyncReceive();
+ }
+
+ protected override IMessage CreateMessage(ISession session)
+ {
+ ITextMessage message = session.CreateTextMessage(expectedText);
+ replyTo = session.CreateTemporaryQueue();
+
+ // lets set the headers
+ message.JMSCorrelationID = correlationID;
+ message.JMSReplyTo = replyTo;
+ message.JMSPersistent = persistent;
+ message.JMSPriority = priority;
+ message.JMSType = type;
+ message.JMSXGroupID = groupID;
+ message.JMSXGroupSeq = groupSeq;
+
+ // lets set the custom headers
+ message.Properties["customText"] = customText;
+ message.Properties["custom1"] = custom1;
+ message.Properties["custom2"] = custom2;
+ message.Properties["custom3"] = custom3;
+ message.Properties["custom4"] = custom4;
+ message.Properties["custom5"] = custom5;
+ message.Properties["custom6"] = custom6;
+
+ return message;
+ }
+
+ protected override void AssertValidMessage(IMessage message)
+ {
+ Assert.IsTrue(message is ITextMessage, "Did not receive a ITextMessage!");
+
+ Console.WriteLine("Received Message: " + message);
+
+ ITextMessage textMessage = (ITextMessage) message;
+ String text = textMessage.Text;
+ Assert.AreEqual(expectedText, text, "the message text");
+
+ // compare standard JMS headers
+ Assert.AreEqual(correlationID, message.JMSCorrelationID, "JMSCorrelationID");
+ Assert.AreEqual(replyTo, message.JMSReplyTo, "JMSReplyTo");
+ Assert.AreEqual(persistent, message.JMSPersistent, "JMSPersistent");
+ Assert.AreEqual(priority, message.JMSPriority, "JMSPriority");
+ Assert.AreEqual(type, message.JMSType, "JMSType");
+ Assert.AreEqual(groupID, message.JMSXGroupID, "JMSXGroupID");
+ Assert.AreEqual(groupSeq, message.JMSXGroupSeq, "JMSXGroupSeq");
+
+ // compare custom headers
+ Assert.AreEqual(customText, message.Properties["customText"], "customText");
+ Assert.AreEqual(custom1, message.Properties["custom1"], "custom1");
+ Assert.AreEqual(custom2, message.Properties["custom2"], "custom2");
+ Assert.AreEqual(custom3, message.Properties["custom3"], "custom3");
+ Assert.AreEqual(custom4, message.Properties["custom4"], "custom4");
+ // TODO
+ Assert.AreEqual(custom5, message.Properties["custom5"], "custom5");
+ Assert.AreEqual(custom6, message.Properties["custom6"], "custom6");
+
+ Assert.AreEqual(custom1, message.Properties.GetBool("custom1"), "custom1");
+ Assert.AreEqual(custom2, message.Properties.GetByte("custom2"), "custom2");
+ Assert.AreEqual(custom3, message.Properties.GetShort("custom3"), "custom3");
+ Assert.AreEqual(custom4, message.Properties.GetInt("custom4"), "custom4");
+ Assert.AreEqual(custom5, message.Properties.GetLong("custom5"), "custom5");
+ Assert.AreEqual(custom6, message.Properties.GetChar("custom6"), "custom6");
+
+ // lets now look at some standard JMS headers
+ Console.WriteLine("JMSExpiration: " + message.JMSExpiration);
+ Console.WriteLine("JMSMessageId: " + message.JMSMessageId);
+ Console.WriteLine("JMSRedelivered: " + message.JMSRedelivered);
+ Console.WriteLine("JMSTimestamp: " + message.JMSTimestamp);
+ Console.WriteLine("JMSXDeliveryCount: " + message.JMSXDeliveryCount);
+ Console.WriteLine("JMSXProducerTXID: " + message.JMSXProducerTXID);
+ }
+ }
+}
+
Modified: incubator/activemq/trunk/openwire-dotnet/tests/ActiveMQ/MapMessageTest.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/tests/ActiveMQ/MapMessageTest.cs?rev=383072&r1=383071&r2=383072&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/tests/ActiveMQ/MapMessageTest.cs (original)
+++ incubator/activemq/trunk/openwire-dotnet/tests/ActiveMQ/MapMessageTest.cs Sat Mar 4 00:19:09 2006
@@ -1,95 +1,92 @@
-/*
- * Copyright 2006 The Apache Software Foundation or its licensors, as
- * applicable.
- *
- * 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.
- */
-using System;
-using System.IO;
-
-using NUnit.Framework;
-
-using OpenWire.Client;
-using OpenWire.Client.Core;
-
-namespace OpenWire.Client
-{
- [ TestFixture ]
- public class MapMessageTest : TestSupport
- {
- bool a = true;
- byte b = 123;
- char c = 'c';
- short d = 0x1234;
- int e = 0x12345678;
- long f = 0x1234567812345678;
- string g = "Hello World!";
-
- [ Test ]
- public override void SendAndSyncReceive()
- {
- base.SendAndSyncReceive();
- }
-
- protected override IMessage CreateMessage(ISession session)
- {
- IMapMessage message = session.CreateMapMessage();
-
- message.Body["a"] = a;
- message.Body["b"] = b;
- message.Body["c"] = c;
- message.Body["d"] = d;
- message.Body["e"] = e;
- message.Body["f"] = f;
- message.Body["g"] = g;
-
- return message;
- }
-
- protected override void AssertValidMessage(IMessage message)
- {
- Assert.IsTrue(message is IMapMessage, "Did not receive a MapMessage!");
- IMapMessage mapMessage = (IMapMessage) message;
-
- Console.WriteLine("Received MapMessage: " + message);
- Console.WriteLine("Received Count: " + mapMessage.Body.Count);
-
- Assert.AreEqual(ToHex(f), ToHex(mapMessage.Body.GetLong("f")), "map entry: f as hex");
-
- // use generic API to access entries
- Assert.AreEqual(a, mapMessage.Body["a"], "generic map entry: a");
- Assert.AreEqual(b, mapMessage.Body["b"], "generic map entry: b");
- Assert.AreEqual(c, mapMessage.Body["c"], "generic map entry: c");
- Assert.AreEqual(d, mapMessage.Body["d"], "generic map entry: d");
- Assert.AreEqual(e, mapMessage.Body["e"], "generic map entry: e");
- Assert.AreEqual(f, mapMessage.Body["f"], "generic map entry: f");
- Assert.AreEqual(g, mapMessage.Body["g"], "generic map entry: g");
-
- // use type safe APIs
- Assert.AreEqual(a, mapMessage.Body.GetBool("a"), "map entry: a");
- Assert.AreEqual(b, mapMessage.Body.GetByte("b"), "map entry: b");
- Assert.AreEqual(c, mapMessage.Body.GetChar("c"), "map entry: c");
- Assert.AreEqual(d, mapMessage.Body.GetShort("d"), "map entry: d");
- Assert.AreEqual(e, mapMessage.Body.GetInt("e"), "map entry: e");
- Assert.AreEqual(f, mapMessage.Body.GetLong("f"), "map entry: f");
- Assert.AreEqual(g, mapMessage.Body.GetString("g"), "map entry: g");
-
-
- }
-
- protected string ToHex(long value)
- {
- return String.Format("{0:x}", value);
- }
- }
-}
+/*
+ * Copyright 2006 The Apache Software Foundation or its licensors, as
+ * applicable.
+ *
+ * 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.
+ */
+using System;
+using System.IO;
+
+using NUnit.Framework;
+
+namespace ActiveMQ
+{
+ [ TestFixture ]
+ public class MapMessageTest : TestSupport
+ {
+ bool a = true;
+ byte b = 123;
+ char c = 'c';
+ short d = 0x1234;
+ int e = 0x12345678;
+ long f = 0x1234567812345678;
+ string g = "Hello World!";
+
+ [ Test ]
+ public override void SendAndSyncReceive()
+ {
+ base.SendAndSyncReceive();
+ }
+
+ protected override IMessage CreateMessage(ISession session)
+ {
+ IMapMessage message = session.CreateMapMessage();
+
+ message.Body["a"] = a;
+ message.Body["b"] = b;
+ message.Body["c"] = c;
+ message.Body["d"] = d;
+ message.Body["e"] = e;
+ message.Body["f"] = f;
+ message.Body["g"] = g;
+
+ return message;
+ }
+
+ protected override void AssertValidMessage(IMessage message)
+ {
+ Assert.IsTrue(message is IMapMessage, "Did not receive a MapMessage!");
+ IMapMessage mapMessage = (IMapMessage) message;
+
+ Console.WriteLine("Received MapMessage: " + message);
+ Console.WriteLine("Received Count: " + mapMessage.Body.Count);
+
+ Assert.AreEqual(ToHex(f), ToHex(mapMessage.Body.GetLong("f")), "map entry: f as hex");
+
+ // use generic API to access entries
+ Assert.AreEqual(a, mapMessage.Body["a"], "generic map entry: a");
+ Assert.AreEqual(b, mapMessage.Body["b"], "generic map entry: b");
+ Assert.AreEqual(c, mapMessage.Body["c"], "generic map entry: c");
+ Assert.AreEqual(d, mapMessage.Body["d"], "generic map entry: d");
+ Assert.AreEqual(e, mapMessage.Body["e"], "generic map entry: e");
+ Assert.AreEqual(f, mapMessage.Body["f"], "generic map entry: f");
+ Assert.AreEqual(g, mapMessage.Body["g"], "generic map entry: g");
+
+ // use type safe APIs
+ Assert.AreEqual(a, mapMessage.Body.GetBool("a"), "map entry: a");
+ Assert.AreEqual(b, mapMessage.Body.GetByte("b"), "map entry: b");
+ Assert.AreEqual(c, mapMessage.Body.GetChar("c"), "map entry: c");
+ Assert.AreEqual(d, mapMessage.Body.GetShort("d"), "map entry: d");
+ Assert.AreEqual(e, mapMessage.Body.GetInt("e"), "map entry: e");
+ Assert.AreEqual(f, mapMessage.Body.GetLong("f"), "map entry: f");
+ Assert.AreEqual(g, mapMessage.Body.GetString("g"), "map entry: g");
+
+
+ }
+
+ protected string ToHex(long value)
+ {
+ return String.Format("{0:x}", value);
+ }
+ }
+}
Modified: incubator/activemq/trunk/openwire-dotnet/tests/ActiveMQ/OpenWire/BooleanStreamTest.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/tests/ActiveMQ/OpenWire/BooleanStreamTest.cs?rev=383072&r1=383071&r2=383072&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/tests/ActiveMQ/OpenWire/BooleanStreamTest.cs (original)
+++ incubator/activemq/trunk/openwire-dotnet/tests/ActiveMQ/OpenWire/BooleanStreamTest.cs Sat Mar 4 00:19:09 2006
@@ -19,10 +19,7 @@
using NUnit.Framework;
-using OpenWire.Client;
-using OpenWire.Client.Core;
-
-namespace OpenWire.Client.Core
+namespace ActiveMQ.OpenWire
{
[TestFixture]
public class BooleanStreamTest : TestSupport
Modified: incubator/activemq/trunk/openwire-dotnet/tests/ActiveMQ/TestMain.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/tests/ActiveMQ/TestMain.cs?rev=383072&r1=383071&r2=383072&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/tests/ActiveMQ/TestMain.cs (original)
+++ incubator/activemq/trunk/openwire-dotnet/tests/ActiveMQ/TestMain.cs Sat Mar 4 00:19:09 2006
@@ -1,80 +1,79 @@
-/*
- * Copyright 2006 The Apache Software Foundation or its licensors, as
- * applicable.
- *
- * 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.
- */
-using System;
-using System.IO;
-
-using OpenWire.Client;
-using OpenWire.Client.Core;
-using OpenWire.Client.Commands;
-
-namespace openwire_dotnet
-{
- public class TestMain
- {
- public static void Main(string[] args)
- {
- try
- {
- Console.WriteLine("About to connect to ActiveMQ");
-
- // START SNIPPET: demo
- IConnectionFactory factory = new ConnectionFactory("localhost", 61616);
- using (IConnection connection = factory.CreateConnection())
- {
- Console.WriteLine("Created a connection!");
-
- ISession session = connection.CreateSession();
-
- IDestination destination = session.GetQueue("FOO.BAR");
- Console.WriteLine("Using destination: " + destination);
-
- // lets create a consumer and producer
- IMessageConsumer consumer = session.CreateConsumer(destination);
-
- IMessageProducer producer = session.CreateProducer(destination);
- producer.Persistent = true;
-
- // lets send a message
- ITextMessage request = session.CreateTextMessage("Hello World!");
- request.JMSCorrelationID = "abc";
- request.JMSXGroupID = "cheese";
- request.Properties["myHeader"] = "James";
-
- producer.Send(request);
-
- // lets consume a message
- ActiveMQTextMessage message = (ActiveMQTextMessage) consumer.Receive();
- if (message == null)
- {
- Console.WriteLine("No message received!");
- }
- else
- {
- Console.WriteLine("Received message with ID: " + message.JMSMessageId);
- Console.WriteLine("Received message with text: " + message.Text);
- }
- }
- // END SNIPPET: demo
- }
- catch (Exception e)
- {
- Console.WriteLine("Caught: " + e);
- Console.WriteLine("Stack: " + e.StackTrace);
- }
- }
- }
-}
+/*
+ * Copyright 2006 The Apache Software Foundation or its licensors, as
+ * applicable.
+ *
+ * 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.
+ */
+using System;
+using System.IO;
+
+using ActiveMQ.OpenWire;
+using ActiveMQ.OpenWire.Commands;
+
+namespace ActiveMQ
+{
+ public class TestMain
+ {
+ public static void Main(string[] args)
+ {
+ try
+ {
+ Console.WriteLine("About to connect to ActiveMQ");
+
+ // START SNIPPET: demo
+ IConnectionFactory factory = new ConnectionFactory("localhost", 61616);
+ using (IConnection connection = factory.CreateConnection())
+ {
+ Console.WriteLine("Created a connection!");
+
+ ISession session = connection.CreateSession();
+
+ IDestination destination = session.GetQueue("FOO.BAR");
+ Console.WriteLine("Using destination: " + destination);
+
+ // lets create a consumer and producer
+ IMessageConsumer consumer = session.CreateConsumer(destination);
+
+ IMessageProducer producer = session.CreateProducer(destination);
+ producer.Persistent = true;
+
+ // lets send a message
+ ITextMessage request = session.CreateTextMessage("Hello World!");
+ request.JMSCorrelationID = "abc";
+ request.JMSXGroupID = "cheese";
+ request.Properties["myHeader"] = "James";
+
+ producer.Send(request);
+
+ // lets consume a message
+ ActiveMQTextMessage message = (ActiveMQTextMessage) consumer.Receive();
+ if (message == null)
+ {
+ Console.WriteLine("No message received!");
+ }
+ else
+ {
+ Console.WriteLine("Received message with ID: " + message.JMSMessageId);
+ Console.WriteLine("Received message with text: " + message.Text);
+ }
+ }
+ // END SNIPPET: demo
+ }
+ catch (Exception e)
+ {
+ Console.WriteLine("Caught: " + e);
+ Console.WriteLine("Stack: " + e.StackTrace);
+ }
+ }
+ }
+}
Modified: incubator/activemq/trunk/openwire-dotnet/tests/ActiveMQ/TestSupport.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/tests/ActiveMQ/TestSupport.cs?rev=383072&r1=383071&r2=383072&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/tests/ActiveMQ/TestSupport.cs (original)
+++ incubator/activemq/trunk/openwire-dotnet/tests/ActiveMQ/TestSupport.cs Sat Mar 4 00:19:09 2006
@@ -19,11 +19,7 @@
using NUnit.Framework;
-using OpenWire.Client;
-using OpenWire.Client.Core;
-
-
-namespace OpenWire.Client
+namespace ActiveMQ
{
/// <summary>