Skip to content

Commit 2221776

Browse files
committed
Added CreateGateway method
1 parent 300f7fe commit 2221776

File tree

1 file changed

+15
-2
lines changed

1 file changed

+15
-2
lines changed

isc/rabbitmq/Utils.cls

Lines changed: 15 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -10,7 +10,20 @@ Parameter BUILDCLASSPATH = "D:\Cache\RabbitMQ\java\out\artifacts\RabbitMQjava_ja
1010

1111
Parameter GATEWAY = "RabbitMQ";
1212

13-
Parameter QUEUE = "hello5";
13+
Parameter QUEUE = "hello";
14+
15+
/// Create JGW. Java home must point to 1.8 jre.
16+
/// Write $System.Status.GetErrorText(##class(isc.rabbitmq.Utils).CreateGateway())
17+
ClassMethod CreateGateway(gatewayName = {..#GATEWAY}, javaHome = {$SYSTEM.Util.GetEnviron("JAVA_HOME")}, path As %String = {..#CLASSPATH}, port As %Integer = 44444)
18+
{
19+
set sys = ##class(%Net.Remote.ObjectGateway).%New()
20+
set sys.Name = gatewayName
21+
set sys.Type = 1
22+
set sys.JavaHome = javaHome
23+
set sys.ClassPath = path
24+
set sys.Port = port
25+
quit sys.%Save()
26+
}
1427

1528
/// Load Jar from path.
1629
/// Write $System.Status.GetErrorText(##class(isc.rabbitmq.Utils).UpdateJar())
@@ -149,7 +162,7 @@ ClassMethod SendMsg(msg = "356") As %Status
149162
Set stream = ##class(%GlobalBinaryStream).%New()
150163
Do stream.Write(msg)
151164

152-
Do api.sendMessageId(stream, "correlationId", "message " _ $zdt($zts,3,1,3))
165+
Do api.sendMessage(stream)
153166

154167

155168
Set sc= gateway.%Disconnect()

0 commit comments

Comments
 (0)