cgl.ogc.wms.services.streaming
Class NBTest

java.lang.Object
  java.lang.Thread
      cgl.ogc.wms.services.streaming.NBTest

All Implemented Interfaces:

cgl.narada.service.client.NBEventListener, java.lang.Runnable

public class NBTest

extends java.lang.Thread

implements cgl.narada.service.client.NBEventListener

Title:

Description:

Copyright: Copyright (c) 2005

Company: Indiana University - Computer Science Dept.

Version:

1.0

Author:

Ahmet Sayar

Field Summary

static int	chk
static int	fcount
(package private) FeatureStreamingFI	gfirh
(package private) java.lang.String	hostName
(package private) FeatureStreaming	hr
(package private) java.lang.String	portNum
(package private) java.io.StringWriter	sw
(package private) java.lang.String	topic

Fields inherited from class java.lang.Thread

MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY

Constructor Summary

NBTest()

NBTest(int entityId, java.lang.String hostName, java.lang.String portNum)

NBTest(int entityId, java.lang.String hostName, java.lang.String portNum, java.lang.String topic)

Method Summary

void	closeBrokerConnection()
void	initializeBrokerCommunications(java.util.Properties props, java.lang.String commType)
void	initializeConsumer(java.lang.String topic)
void	initializeSubscriber(java.lang.String hostName, java.lang.String portNumber, java.lang.String topic)
static void	main(java.lang.String[] args)
void	onEvent(cgl.narada.event.NBEvent nbEvent)
void	run()
void	unsubscribe()

Methods inherited from class java.lang.Thread

activeCount, checkAccess, countStackFrames, currentThread, destroy, dumpStack, enumerate, getContextClassLoader, getName, getPriority, getThreadGroup, holdsLock, interrupt, interrupted, isAlive, isDaemon, isInterrupted, join, join, join, resume, setContextClassLoader, setDaemon, setName, setPriority, sleep, sleep, start, stop, stop, suspend, toString, yield

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Field Detail

sw

java.io.StringWriter sw

fcount

public static int fcount

hostName

java.lang.String hostName

portNum

java.lang.String portNum

topic

java.lang.String topic

hr

FeatureStreaming hr

gfirh

FeatureStreamingFI gfirh

chk

public static int chk

Constructor Detail

NBTest

public NBTest(int entityId,
              java.lang.String hostName,
              java.lang.String portNum,
              java.lang.String topic)

Parameters:

entityId - int

hostName - String

portNum - String

topic - String

NBTest

public NBTest(int entityId,
              java.lang.String hostName,
              java.lang.String portNum)

Parameters:

entityId - int

hostName - String

portNum - String

NBTest

public NBTest()

Method Detail

initializeBrokerCommunications

public void initializeBrokerCommunications(java.util.Properties props,
                                           java.lang.String commType)
                                    throws cgl.narada.service.ServiceException

Parameters:

props - Properties

commType - String

Throws:

cgl.narada.service.ServiceException

closeBrokerConnection

public void closeBrokerConnection()
                           throws cgl.narada.service.ServiceException

Throws:

cgl.narada.service.ServiceException

initializeConsumer

public void initializeConsumer(java.lang.String topic)
                        throws cgl.narada.service.ServiceException

Parameters:

topic - String

Throws:

cgl.narada.service.ServiceException

unsubscribe

public void unsubscribe()
                 throws cgl.narada.service.ServiceException

Throws:

cgl.narada.service.ServiceException

onEvent

public void onEvent(cgl.narada.event.NBEvent nbEvent)

Specified by:

onEvent in interface cgl.narada.service.client.NBEventListener

Parameters:

nbEvent - NBEvent

initializeSubscriber

public void initializeSubscriber(java.lang.String hostName,
                                 java.lang.String portNumber,
                                 java.lang.String topic)

Parameters:

hostName - String

portNumber - String

topic - String

main

public static void main(java.lang.String[] args)

Parameters:

args - String[]

run

public void run()

Specified by:

run in interface java.lang.Runnable