mirror of https://github.com/apache/activemq.git
latest generated openwire.net code which now compiles OK!
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@367314 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
parent
f4f8bb12ed
commit
6f4386d1cd
|
@ -0,0 +1,32 @@
|
|||
using System;
|
||||
using OpenWire.Core;
|
||||
using OpenWire.Core.Commands;
|
||||
|
||||
namespace OpenWire.Core
|
||||
{
|
||||
/// <summary>
|
||||
/// Summary description for ActiveMQTempTopic.
|
||||
/// </summary>
|
||||
public class ActiveMQTempTopic : ActiveMQDestination, TemporaryTopic
|
||||
{
|
||||
public const byte ID_ActiveMQTempTopic = 103;
|
||||
|
||||
public ActiveMQTempTopic(): base() {}
|
||||
public ActiveMQTempTopic(String name):base(name){}
|
||||
|
||||
public String GetTopicName()
|
||||
{
|
||||
return PhysicalName;
|
||||
}
|
||||
public override int GetDestinationType()
|
||||
{
|
||||
return ACTIVEMQ_TOPIC;
|
||||
}
|
||||
|
||||
public override ActiveMQDestination CreateDestination(String name)
|
||||
{
|
||||
return new ActiveMQTempTopic(name);
|
||||
}
|
||||
|
||||
}
|
||||
}
|
|
@ -0,0 +1,46 @@
|
|||
//
|
||||
// Marshalling code for Open Wire Format for DiscoveryEvent
|
||||
//
|
||||
//
|
||||
// NOTE!: This file is autogenerated - do not modify!
|
||||
// if you need to make a change, please see the Groovy scripts in the
|
||||
// activemq-openwire module
|
||||
//
|
||||
|
||||
using System;
|
||||
using System.Collections;
|
||||
using System.IO;
|
||||
|
||||
using OpenWire.Core;
|
||||
using OpenWire.Core.Commands;
|
||||
using OpenWire.Core.IO;
|
||||
|
||||
namespace OpenWire.Core.IO
|
||||
{
|
||||
public class DiscoveryEventMarshaller : AbstractCommandMarshaller
|
||||
{
|
||||
|
||||
|
||||
public override Command CreateCommand() {
|
||||
return new DiscoveryEvent();
|
||||
}
|
||||
|
||||
public override void BuildCommand(Command command, BinaryReader dataIn) {
|
||||
base.BuildCommand(command, dataIn);
|
||||
|
||||
DiscoveryEvent info = (DiscoveryEvent) command;
|
||||
info.ServiceName = dataIn.ReadString();
|
||||
info.BrokerName = dataIn.ReadString();
|
||||
|
||||
}
|
||||
|
||||
public override void WriteCommand(Command command, BinaryWriter dataOut) {
|
||||
base.WriteCommand(command, dataOut);
|
||||
|
||||
DiscoveryEvent info = (DiscoveryEvent) command;
|
||||
dataOut.Write(info.ServiceName);
|
||||
dataOut.Write(info.BrokerName);
|
||||
|
||||
}
|
||||
}
|
||||
}
|
|
@ -0,0 +1,12 @@
|
|||
using System;
|
||||
using OpenWire.Core.Commands;
|
||||
|
||||
namespace OpenWire.Core
|
||||
{
|
||||
/// <summary>
|
||||
/// Summary description for TemporaryQueue.
|
||||
/// </summary>
|
||||
public interface TemporaryQueue : Destination
|
||||
{
|
||||
}
|
||||
}
|
Loading…
Reference in New Issue