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()