本文整理汇总了Java中com.esri.ges.core.component.RunningState类的典型用法代码示例。如果您正苦于以下问题：Java RunningState类的具体用法？Java RunningState怎么用？Java RunningState使用的例子？那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。
RunningState类属于com.esri.ges.core.component包，在下文中一共展示了RunningState类的20个代码示例，这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞，您的评价将有助于我们的系统推荐出更棒的Java代码示例。
示例1: receive
import com.esri.ges.core.component.RunningState; //导入依赖的package包/类
public void receive(ByteBuffer bb, String channelId) {
if (getRunningState() == RunningState.STARTED) {
receiving = true;
synchronized (buffer) {
try {
if (buffer.remaining() < bb.remaining())
log.error("The TCP/IP outbound transport is unable to keep up with the incoming data rate, dropping "
+ bb.remaining() + " bytes.");
else
buffer.put(bb);
} catch (BufferOverflowException ex) {
log.error("The TCP/IP outbound transport is unable to keep up with the incoming data rate, dropping "
+ bb.remaining() + " bytes.");
}
}
wakupThread();
}
}
开发者ID:Esri，项目名称:defense-solutions-proofs-of-concept，代码行数:24，代码来源:TcpSquirtOutboundTransport.java
示例2: readProperties
import com.esri.ges.core.component.RunningState; //导入依赖的package包/类
private void readProperties()
{
Property prop = getProperty( "host" );
host = prop.getValueAsString();
prop = getProperty( "port" );
port = (Integer)prop.getValue();
prop = getProperty( "mode" );
String modeString = prop.getValueAsString();
clientConnectionTimeout = hasProperty("clientConnectionTimeout") ? (Integer) getProperty("clientConnectionTimeout").getValue() : 60;
if( modeString != null && modeString.toUpperCase().trim().equals("CLIENT") )
mode = CLIENT;
else if( modeString != null && modeString.toUpperCase().trim().equals("SERVER") )
mode = SERVER;
else
{
log.error("Setting the TCP Transport to mode \""+modeString+"\" is not allowed. Must be SERVER or CLIENT.");
setRunningState(RunningState.ERROR);
return;
}
}
开发者ID:Esri，项目名称:defense-solutions-proofs-of-concept，代码行数:21，代码来源:TcpSquirtOutboundTransport.java
示例3: afterPropertiesSet
import com.esri.ges.core.component.RunningState; //导入依赖的package包/类
@Override
public void afterPropertiesSet()
{
try
{
readProperties();
if( getRunningState() == RunningState.STARTED )
{
cleanup();
applyProperties();
}
}catch( IOException ex )
{
errorMessage = ex.getMessage();
log.error(errorMessage);
setRunningState(RunningState.ERROR);
}
}
开发者ID:Esri，项目名称:defense-solutions-proofs-of-concept，代码行数:19，代码来源:TcpSquirtOutboundTransport.java
示例4: start
import com.esri.ges.core.component.RunningState; //导入依赖的package包/类
@SuppressWarnings("incomplete-switch")
@Override
public synchronized void start()
{
switch (getRunningState())
{
case STARTING:
case STARTED:
case ERROR:
return;
}
setRunningState(RunningState.STARTING);
setup();
context = new HttpTransportContext();
context.setHttpClientService(httpClientService);
setRunningState(RunningState.STARTED);
setErrorMessage(null);
startCleanUpThread();
}
开发者ID:Esri，项目名称:defense-solutions-proofs-of-concept，代码行数:20，代码来源:MLOBIOutboundTransport.java
示例5: startCleanUpThread
import com.esri.ges.core.component.RunningState; //导入依赖的package包/类
private void startCleanUpThread()
{
if (cleanupOldFeatures && !cleanupTimeField.isEmpty())
{
if (cleanupThread == null && (getRunningState() == RunningState.STARTED || getRunningState() == RunningState.STARTING))
{
cleanupThread = new CleanupThread();
cleanupThread.setName("OutboundFeatureServiceCleanerThread-" + layerDescriptionForLogs);
cleanupThread.setDaemon(true);
cleanupThread.start();
}
}
else
{
if (cleanupThread != null)
{
cleanupThread.dismiss();
cleanupThread = null;
}
}
}
开发者ID:Esri，项目名称:defense-solutions-proofs-of-concept，代码行数:22，代码来源:MLOBIOutboundTransport.java
示例6: stop
import com.esri.ges.core.component.RunningState; //导入依赖的package包/类
private void stop(boolean unregisterAsListener)
{
if (getRunningState() == RunningState.STARTED)
{
setRunningState(RunningState.STOPPING);
runThread.dismiss();
runThread.interrupt();
runThread = null;
}
setRunningState(RunningState.STOPPED);
setErrorMessage(null);
if (unregisterAsListener)
{
try
{
disconnectOBI();
token = null;
}
catch (Throwable t)
{
// Chances are, system is shutting down and agsManager instance has gone away.
LOGGER.info("STOP_ERROR", t.getMessage());
}
}
}
开发者ID:Esri，项目名称:defense-solutions-proofs-of-concept，代码行数:26，代码来源:MLOBIInboundTransport.java
示例7: run
import com.esri.ges.core.component.RunningState; //导入依赖的package包/类
@Override
public void run()
{
setErrorMessage("");
setRunningState(RunningState.STARTED);
while (isRunning())
{
try
{
byte[] bytes = consumer.receive();
if (bytes != null && bytes.length > 0) {
ByteBuffer bb = ByteBuffer.allocate(bytes.length);
bb.put(bytes);
bb.flip();
byteListener.receive(bb, "");
bb.clear();
}
}
catch (MessagingException e)
{
LOGGER.error("", e);
}
}
}
开发者ID:Esri，项目名称:kafka-for-geoevent，代码行数:25，代码来源:KafkaInboundTransport.java
示例8: connect
import com.esri.ges.core.component.RunningState; //导入依赖的package包/类
private synchronized void connect()
{
disconnect("");
setRunningState(RunningState.STARTING);
if (consumer == null)
consumer = new KafkaEventConsumer();
if (consumer.getStatusDetails().isEmpty()) // no errors reported while instantiating a consumer
{
consumer.setConnected();
new Thread(this).start();
}
else
{
setRunningState(RunningState.ERROR);
setErrorMessage(consumer.getStatusDetails());
}
}
开发者ID:Esri，项目名称:kafka-for-geoevent，代码行数:18，代码来源:KafkaInboundTransport.java
示例9: start
import com.esri.ges.core.component.RunningState; //导入依赖的package包/类
@SuppressWarnings("incomplete-switch")
public void start() throws RunningException
{
try
{
switch (getRunningState())
{
case STARTING:
case STARTED:
case STOPPING:
return;
}
setRunningState(RunningState.STARTING);
thread = new Thread(this);
thread.start();
}
catch (Exception e)
{
LOGGER.error("UNEXPECTED_ERROR_STARTING", e);
stop();
}
}
开发者ID:Esri，项目名称:aws-for-geoevent，代码行数:23，代码来源:AwsIoTHubInboundTransport.java
示例10: start
import com.esri.ges.core.component.RunningState; //导入依赖的package包/类
@Override
public void start() throws RunningException
{
try
{
setRunningState(RunningState.STARTING);
connectToAwsEventHub();
setRunningState(RunningState.STARTED);
}
catch (Exception e)
{
LOGGER.error("INIT_ERROR", e);
setErrorMessage(e.getMessage());
setRunningState(RunningState.ERROR);
}
}
开发者ID:Esri，项目名称:aws-for-geoevent，代码行数:18，代码来源:AwsIoTHubOutboundTransport.java
示例11: start
import com.esri.ges.core.component.RunningState; //导入依赖的package包/类
@SuppressWarnings("incomplete-switch")
public void start() throws RunningException
{
try
{
switch (getRunningState())
{
case STARTING:
case STARTED:
case STOPPING:
return;
}
setRunningState(RunningState.STARTING);
thread = new Thread(this);
thread.start();
}
catch (Exception e)
{
log.error("UNEXPECTED_ERROR_STARTING", e);
stop();
}
}
开发者ID:Esri，项目名称:mqtt-for-geoevent，代码行数:23，代码来源:MqttInboundTransport.java
示例12: stop
import com.esri.ges.core.component.RunningState; //导入依赖的package包/类
public synchronized void stop()
{
try
{
if (this.mqttClient != null)
{
this.mqttClient.disconnect();
this.mqttClient.close();
}
}
catch (MqttException ex)
{
log.error("UNABLE_TO_CLOSE", ex);
}
setRunningState(RunningState.STOPPED);
}
开发者ID:Esri，项目名称:mqtt-for-geoevent，代码行数:17，代码来源:MqttInboundTransport.java
示例13: start
import com.esri.ges.core.component.RunningState; //导入依赖的package包/类
@Override
public void start() throws RunningException
{
try
{
setRunningState(RunningState.STARTING);
applyProperties();
connectMqtt();
setRunningState(RunningState.STARTED);
}
catch (Exception e)
{
log.error("INIT_ERROR", e, this.getClass().getName());
setRunningState(RunningState.ERROR);
}
}
开发者ID:Esri，项目名称:mqtt-for-geoevent，代码行数:17，代码来源:MqttOutboundTransport.java
示例14: connect
import com.esri.ges.core.component.RunningState; //导入依赖的package包/类
private synchronized void connect()
{
disconnect("");
setRunningState(RunningState.STARTING);
try
{
if (producer == null)
{
producer = new RabbitMQProducer(connectionInfo, exchange);
producer.addObserver(this);
}
producer.connect();
setRunningState(RunningState.STARTED);
}
catch (RabbitMQTransportException e)
{
disconnect(e.getMessage());
setRunningState(RunningState.ERROR);
}
}
开发者ID:Esri，项目名称:rabbitmq-for-geoevent，代码行数:21，代码来源:RabbitMQOutboundTransport.java
示例15: run
import com.esri.ges.core.component.RunningState; //导入依赖的package包/类
@Override
public void run()
{
setErrorMessage("");
setRunningState(RunningState.STARTED);
while (isRunning())
{
try
{
byte[] bytes = consumer.receive();
if (bytes != null && bytes.length > 0)
{
ByteBuffer bb = ByteBuffer.allocate(bytes.length);
bb.put(bytes);
bb.flip();
byteListener.receive(bb, "");
bb.clear();
}
}
catch (RabbitMQTransportException e)
{
LOGGER.error("", e);
}
}
}
开发者ID:Esri，项目名称:rabbitmq-for-geoevent，代码行数:26，代码来源:RabbitMQInboundTransport.java
示例16: connect
import com.esri.ges.core.component.RunningState; //导入依赖的package包/类
private synchronized void connect()
{
disconnect("");
setRunningState(RunningState.STARTING);
try
{
if (consumer == null)
{
consumer = new RabbitMQConsumer(connectionInfo, exchange, queue);
consumer.addObserver(this);
}
consumer.setPrefetchCount(prefetchCount);
consumer.connect();
new Thread(this).start();
}
catch (RabbitMQTransportException e)
{
disconnect(e.getMessage());
setRunningState(RunningState.ERROR);
}
}
开发者ID:Esri，项目名称:rabbitmq-for-geoevent，代码行数:22，代码来源:RabbitMQInboundTransport.java
示例17: start
import com.esri.ges.core.component.RunningState; //导入依赖的package包/类
@Override
public synchronized void start()
{
try
{
switch (getRunningState())
{
case STARTING:
case STARTED:
case STOPPING:
return;
}
setRunningState(RunningState.STARTING);
thread = new Thread(this);
thread.start();
}
catch (Exception e)
{
LOGGER.error("UNEXPECTED_ERROR_STARTING", e);
stop();
}
}
开发者ID:Esri，项目名称:twitter-for-geoevent，代码行数:23，代码来源:TwitterInboundTransport.java
示例18: stop
import com.esri.ges.core.component.RunningState; //导入依赖的package包/类
@Override
public synchronized void stop()
{
try
{
if (this.twitterStream != null)
{
twitterStream.cleanUp();
twitterStream.shutdown();
}
}
catch (Exception ex)
{
LOGGER.error("UNABLE_TO_CLOSE", ex);
}
setRunningState(RunningState.STOPPED);
LOGGER.debug("INBOUND_STOP");
}
开发者ID:Esri，项目名称:twitter-for-geoevent，代码行数:19，代码来源:TwitterInboundTransport.java
示例19: afterPropertiesSet
import com.esri.ges.core.component.RunningState; //导入依赖的package包/类
@Override
public void afterPropertiesSet()
{
try
{
readProperties();
if (getRunningState() == RunningState.STARTED)
{
cleanup();
applyProperties();
}
}
catch (Exception error)
{
errorMessage = error.getMessage();
LOGGER.error(errorMessage, error);
setRunningState(RunningState.ERROR);
}
}
开发者ID:Esri，项目名称:mongodb-for-geoevent，代码行数:20，代码来源:MongoDBOutboundTransport.java
示例20: receive
import com.esri.ges.core.component.RunningState; //导入依赖的package包/类
@Override
public void receive(ByteBuffer buffer, String channelId)
{
if (this.getRunningState() == RunningState.STARTED)
{
try
{
String json = convertToString(buffer);
DBObject dbObj = (DBObject) com.mongodb.util.JSON.parse(json);
collection.insert(dbObj);
}
catch (Exception error)
{
LOGGER.error("RECEIVE_ERROR", error.getMessage());
LOGGER.info(error.getMessage(), error);
}
}
}
开发者ID:Esri，项目名称:mongodb-for-geoevent，代码行数:19，代码来源:MongoDBOutboundTransport.java
注：本文中的com.esri.ges.core.component.RunningState类示例整理自Github/MSDocs等源码及文档管理平台，相关代码片段筛选自各路编程大神贡献的开源项目，源码版权归原作者所有，传播和使用请参考对应项目的License；未经允许，请勿转载。 |
客服电话
APP下载
官方微信
请发表评论