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 2007/02/14 21:43:54 UTC
svn commit: r507686 - in /activemq/activemq-dotnet/trunk: ./
src/main/csharp/ActiveMQ/Commands/ src/main/csharp/MSMQ/
Author: chirino
Date: Wed Feb 14 12:43:53 2007
New Revision: 507686
URL: http://svn.apache.org/viewvc?view=rev&rev=507686
Log:
Object Serializtion is not supported under the Compact Framework 2.0.
Conditionaly compile out the ObjectMessage implementation when running in that env.
Updated VS builds files to include new source files.
Modified:
activemq/activemq-dotnet/trunk/src/main/csharp/ActiveMQ/Commands/ActiveMQObjectMessage.cs
activemq/activemq-dotnet/trunk/src/main/csharp/MSMQ/MessageProducer.cs
activemq/activemq-dotnet/trunk/src/main/csharp/MSMQ/Session.cs
activemq/activemq-dotnet/trunk/vs2005-activemq-cf20.csproj
activemq/activemq-dotnet/trunk/vs2005-activemq.csproj
activemq/activemq-dotnet/trunk/vs2005-nms-cf20.csproj
activemq/activemq-dotnet/trunk/vs2005-nms.csproj
Modified: activemq/activemq-dotnet/trunk/src/main/csharp/ActiveMQ/Commands/ActiveMQObjectMessage.cs
URL: http://svn.apache.org/viewvc/activemq/activemq-dotnet/trunk/src/main/csharp/ActiveMQ/Commands/ActiveMQObjectMessage.cs?view=diff&rev=507686&r1=507685&r2=507686
==============================================================================
--- activemq/activemq-dotnet/trunk/src/main/csharp/ActiveMQ/Commands/ActiveMQObjectMessage.cs (original)
+++ activemq/activemq-dotnet/trunk/src/main/csharp/ActiveMQ/Commands/ActiveMQObjectMessage.cs Wed Feb 14 12:43:53 2007
@@ -18,8 +18,11 @@
using System;
using System.Collections;
using System.IO;
+
+#if !(PocketPC||NETCF||NETCF_2_0)
using System.Runtime.Serialization;
using System.Runtime.Serialization.Formatters.Binary;
+#endif
using ActiveMQ.OpenWire;
using ActiveMQ.Commands;
@@ -39,9 +42,10 @@
{
public const byte ID_ActiveMQObjectMessage = 26;
+#if !(PocketPC||NETCF||NETCF_2_0)
private object body;
- private IFormatter formatter;
-
+ private IFormatter formatter;
+#endif
public override string ToString() {
return GetType().Name + "["
@@ -59,19 +63,28 @@
{
get
{
+#if !(PocketPC||NETCF||NETCF_2_0)
if (body == null)
{
body = Formatter.Deserialize(new MemoryStream(Content));
}
return body;
+#else
+ throw new NotImplementedException();
+#endif
}
set
{
+#if !(PocketPC||NETCF||NETCF_2_0)
body = value;
- }
+#else
+ throw new NotImplementedException();
+#endif
+ }
}
-
+
+#if !(PocketPC||NETCF||NETCF_2_0)
public override void BeforeMarshall(OpenWireFormat wireFormat)
{
if (body == null)
@@ -106,5 +119,6 @@
formatter = value;
}
}
+#endif
}
}
Modified: activemq/activemq-dotnet/trunk/src/main/csharp/MSMQ/MessageProducer.cs
URL: http://svn.apache.org/viewvc/activemq/activemq-dotnet/trunk/src/main/csharp/MSMQ/MessageProducer.cs?view=diff&rev=507686&r1=507685&r2=507686
==============================================================================
--- activemq/activemq-dotnet/trunk/src/main/csharp/MSMQ/MessageProducer.cs (original)
+++ activemq/activemq-dotnet/trunk/src/main/csharp/MSMQ/MessageProducer.cs Wed Feb 14 12:43:53 2007
@@ -162,6 +162,11 @@
}
}
+ public void Send(IDestination destination, IMessage message, bool persistent, byte priority, TimeSpan timeToLive)
+ {
+ throw new NotImplementedException();
+ }
+
public void Dispose()
{
if( messageQueue!=null )
@@ -181,6 +186,12 @@
{
get { return timeToLive; }
set { timeToLive = value; }
+ }
+
+ byte IMessageProducer.Priority
+ {
+ get { throw new NotImplementedException(); }
+ set { throw new NotImplementedException(); }
}
public int Priority
Modified: activemq/activemq-dotnet/trunk/src/main/csharp/MSMQ/Session.cs
URL: http://svn.apache.org/viewvc/activemq/activemq-dotnet/trunk/src/main/csharp/MSMQ/Session.cs?view=diff&rev=507686&r1=507685&r2=507686
==============================================================================
--- activemq/activemq-dotnet/trunk/src/main/csharp/MSMQ/Session.cs (original)
+++ activemq/activemq-dotnet/trunk/src/main/csharp/MSMQ/Session.cs Wed Feb 14 12:43:53 2007
@@ -68,7 +68,12 @@
{
return new MessageConsumer(this, acknowledgementMode);
}
-
+
+ public IMessageConsumer CreateConsumer(IDestination destination, string selector, bool noLocal)
+ {
+ throw new NotImplementedException();
+ }
+
public IMessageConsumer CreateDurableConsumer(ITopic destination, string name, string selector, bool noLocal)
{
return null;
@@ -158,7 +163,12 @@
{
get { return acknowledgementMode == AcknowledgementMode.Transactional; }
}
-
+
+ public AcknowledgementMode AcknowledgementMode
+ {
+ get { throw new NotImplementedException(); }
+ }
+
public MessageQueueTransaction MessageQueueTransaction
{
get
Modified: activemq/activemq-dotnet/trunk/vs2005-activemq-cf20.csproj
URL: http://svn.apache.org/viewvc/activemq/activemq-dotnet/trunk/vs2005-activemq-cf20.csproj?view=diff&rev=507686&r1=507685&r2=507686
==============================================================================
--- activemq/activemq-dotnet/trunk/vs2005-activemq-cf20.csproj (original)
+++ activemq/activemq-dotnet/trunk/vs2005-activemq-cf20.csproj Wed Feb 14 12:43:53 2007
@@ -691,6 +691,7 @@
<Compile Include="src\main\csharp\ActiveMQ\Transport\ITransportFactory.cs">
<SubType>Code</SubType>
</Compile>
+ <Compile Include="src\main\csharp\ActiveMQ\Transport\IWireFormat.cs" />
<Compile Include="src\main\csharp\ActiveMQ\Transport\LoggingTransport.cs">
<SubType>Code</SubType>
</Compile>
@@ -700,6 +701,7 @@
<Compile Include="src\main\csharp\ActiveMQ\Transport\ResponseCorrelator.cs">
<SubType>Code</SubType>
</Compile>
+ <Compile Include="src\main\csharp\ActiveMQ\Transport\Stomp\StompWireFormat.cs" />
<Compile Include="src\main\csharp\ActiveMQ\Transport\Tcp\TcpTransport.cs">
<SubType>Code</SubType>
</Compile>
Modified: activemq/activemq-dotnet/trunk/vs2005-activemq.csproj
URL: http://svn.apache.org/viewvc/activemq/activemq-dotnet/trunk/vs2005-activemq.csproj?view=diff&rev=507686&r1=507685&r2=507686
==============================================================================
--- activemq/activemq-dotnet/trunk/vs2005-activemq.csproj (original)
+++ activemq/activemq-dotnet/trunk/vs2005-activemq.csproj Wed Feb 14 12:43:53 2007
@@ -674,6 +674,7 @@
<Compile Include="src\main\csharp\ActiveMQ\Transport\ITransportFactory.cs">
<SubType>Code</SubType>
</Compile>
+ <Compile Include="src\main\csharp\ActiveMQ\Transport\IWireFormat.cs" />
<Compile Include="src\main\csharp\ActiveMQ\Transport\LoggingTransport.cs">
<SubType>Code</SubType>
</Compile>
@@ -683,6 +684,7 @@
<Compile Include="src\main\csharp\ActiveMQ\Transport\ResponseCorrelator.cs">
<SubType>Code</SubType>
</Compile>
+ <Compile Include="src\main\csharp\ActiveMQ\Transport\Stomp\StompWireFormat.cs" />
<Compile Include="src\main\csharp\ActiveMQ\Transport\Tcp\TcpTransport.cs">
<SubType>Code</SubType>
</Compile>
Modified: activemq/activemq-dotnet/trunk/vs2005-nms-cf20.csproj
URL: http://svn.apache.org/viewvc/activemq/activemq-dotnet/trunk/vs2005-nms-cf20.csproj?view=diff&rev=507686&r1=507685&r2=507686
==============================================================================
--- activemq/activemq-dotnet/trunk/vs2005-nms-cf20.csproj (original)
+++ activemq/activemq-dotnet/trunk/vs2005-nms-cf20.csproj Wed Feb 14 12:43:53 2007
@@ -59,6 +59,7 @@
<Compile Include="src\main\csharp\NMS\IMessage.cs" />
<Compile Include="src\main\csharp\NMS\IMessageConsumer.cs" />
<Compile Include="src\main\csharp\NMS\IMessageProducer.cs" />
+ <Compile Include="src\main\csharp\NMS\IObjectMessage.cs" />
<Compile Include="src\main\csharp\NMS\IPrimitiveMap.cs" />
<Compile Include="src\main\csharp\NMS\IQueue.cs" />
<Compile Include="src\main\csharp\NMS\ISession.cs" />
@@ -69,6 +70,7 @@
<Compile Include="src\main\csharp\NMS\ITextMessage.cs" />
<Compile Include="src\main\csharp\NMS\ITopic.cs" />
<Compile Include="src\main\csharp\NMS\NMSConnectionException.cs" />
+ <Compile Include="src\main\csharp\NMS\NMSConstants.cs" />
<Compile Include="src\main\csharp\NMS\NMSException.cs" />
<Compile Include="src\main\csharp\NMS\NMSSecurityException.cs" />
</ItemGroup>
Modified: activemq/activemq-dotnet/trunk/vs2005-nms.csproj
URL: http://svn.apache.org/viewvc/activemq/activemq-dotnet/trunk/vs2005-nms.csproj?view=diff&rev=507686&r1=507685&r2=507686
==============================================================================
--- activemq/activemq-dotnet/trunk/vs2005-nms.csproj (original)
+++ activemq/activemq-dotnet/trunk/vs2005-nms.csproj Wed Feb 14 12:43:53 2007
@@ -44,6 +44,7 @@
<Compile Include="src\main\csharp\NMS\IMessage.cs" />
<Compile Include="src\main\csharp\NMS\IMessageConsumer.cs" />
<Compile Include="src\main\csharp\NMS\IMessageProducer.cs" />
+ <Compile Include="src\main\csharp\NMS\IObjectMessage.cs" />
<Compile Include="src\main\csharp\NMS\IPrimitiveMap.cs" />
<Compile Include="src\main\csharp\NMS\IQueue.cs" />
<Compile Include="src\main\csharp\NMS\ISession.cs" />
@@ -54,6 +55,7 @@
<Compile Include="src\main\csharp\NMS\ITextMessage.cs" />
<Compile Include="src\main\csharp\NMS\ITopic.cs" />
<Compile Include="src\main\csharp\NMS\NMSConnectionException.cs" />
+ <Compile Include="src\main\csharp\NMS\NMSConstants.cs" />
<Compile Include="src\main\csharp\NMS\NMSException.cs" />
<Compile Include="src\main\csharp\NMS\NMSSecurityException.cs" />
</ItemGroup>