cgl.ogc.wms.services.streaming
Class SimpleClient

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

All Implemented Interfaces:

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

public class SimpleClient

extends java.lang.Thread

implements cgl.narada.service.client.NBEventListener

Title:

Description:

Copyright: Copyright (c) 2005

Company:

Version:

1.0

Author:

Ahmet Sayar

Field Summary

int	chk
(package private) java.lang.String	cpayload
int	fcount
(package private) FeatureStreaming	fs
(package private) FeatureStreamingFI	fsfi
java.lang.String	uuid

Fields inherited from class java.lang.Thread

MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY

Constructor Summary

SimpleClient(int entityId, java.lang.String tpc, FeatureStreaming fst)

SimpleClient(int entityId, java.lang.String tpc, FeatureStreamingFI fstfi)

Method Summary

void	closeBrokerConnection()
java.lang.String	getCPayLoad()
java.lang.String	getUuid()
void	initializeBrokerCommunications(java.util.Properties props, java.lang.String commType)
void	initializeConsumer()
void	initializeProducer()
static void	main(java.lang.String[] args)
void	onEvent(cgl.narada.event.NBEvent nbEvent)
void	processEventProperties(cgl.narada.event.NBEvent nbEvent)
void	publishEvent(java.lang.String stringMsg)
void	run()
void	runNB(SimpleClient client, java.util.Properties props, java.lang.String module)
void	setCPayLoad(java.lang.String ggg)
void	setUuid(java.lang.String id)
void	startNBStreaming()
void	stopNBStreaming()
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

fcount

public int fcount

fs

FeatureStreaming fs

fsfi

FeatureStreamingFI fsfi

chk

public int chk

cpayload

java.lang.String cpayload

uuid

public java.lang.String uuid

Constructor Detail

SimpleClient

public SimpleClient(int entityId,
                    java.lang.String tpc,
                    FeatureStreaming fst)

Parameters:

entityId - int

tpc - String

fst - FeatureStreaming

SimpleClient

public SimpleClient(int entityId,
                    java.lang.String tpc,
                    FeatureStreamingFI fstfi)

Parameters:

entityId - int

tpc - String

fstfi - FeatureStreamingFI

Method Detail

run

public void run()

Specified by:

run in interface java.lang.Runnable

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

initializeProducer

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

Throws:

cgl.narada.service.ServiceException

initializeConsumer

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

Throws:

cgl.narada.service.ServiceException

unsubscribe

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

Throws:

cgl.narada.service.ServiceException

publishEvent

public void publishEvent(java.lang.String stringMsg)
                  throws cgl.narada.service.ServiceException,
                         cgl.narada.event.NBEventException

Parameters:

stringMsg - String

Throws:

cgl.narada.service.ServiceException

cgl.narada.event.NBEventException

onEvent

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

Specified by:

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

Parameters:

nbEvent - NBEvent

processEventProperties

public void processEventProperties(cgl.narada.event.NBEvent nbEvent)
                            throws cgl.narada.event.NBEventException

Parameters:

nbEvent - NBEvent

Throws:

cgl.narada.event.NBEventException

main

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

Parameters:

args - String[]

runNB

public void runNB(SimpleClient client,
                  java.util.Properties props,
                  java.lang.String module)

Parameters:

client - SimpleClient

props - Properties

module - String

startNBStreaming

public void startNBStreaming()

stopNBStreaming

public void stopNBStreaming()

getCPayLoad

public java.lang.String getCPayLoad()

Returns:

String

setCPayLoad

public void setCPayLoad(java.lang.String ggg)

Returns:

String

getUuid

public java.lang.String getUuid()

Returns:

String

setUuid

public void setUuid(java.lang.String id)

Returns:

String