1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
|
from jpype import *
import time
def pySubscriber (proxy,
javaNamingFactory="weblogic.jndi.WLInitialContextFactory",
javaNamingProvider="t3://158.188.40.21:7001",
connectionFactory="weblogic.jms.ConnectionFactory",
topicName="defaultTopic"):
return messaging.JpypeSubscriber(proxy,javaNamingFactory,javaNamingProvider,
connectionFactory,topicName)
## Startup Jpype and import the messaging java package
startJVM("C:\\program files\\Java\\j2re1.4.2_02\\bin\\client\\jvm.dll",
"-Djava.class.path=D:/jIRAD/JpypeJMS/src;D:/jIRAD/JpypeJMS/classes;C:/bea/weblogic81/server/lib/weblogic.jar")
messaging = JPackage('messaging')
# Setup the JProxy for the messaging.JpypeSubscriberCallback interface
class pyCallback:
startTime = 0
count = 0
def onMessage (self,text):
print text
if text=='Start':
pyCallback.startTime=time.time()
pyCallback.count = 0
elif text=='Stop':
print "Message Rate =",float(pyCallback.count)/(time.time()-pyCallback.startTime)
else:
pyCallback.count += 1
c = pyCallback()
proxy = JProxy(messaging.JpypeSubscriberCallback,inst=c)
# Get a subscriber
sub = pySubscriber(proxy)
print "Listening..."
# Prevent this thread from exiting
time.sleep(1000)
# exit
shutdownJVM()
|
