• 设为首页
  • 点击收藏
  • 手机版
    手机扫一扫访问
    迪恩网络手机版
  • 关注官方公众号
    微信扫一扫关注
    公众号

Java RunningException类代码示例

原作者: [db:作者] 来自: [db:来源] 收藏 邀请

本文整理汇总了Java中com.esri.ges.core.component.RunningException的典型用法代码示例。如果您正苦于以下问题:Java RunningException类的具体用法?Java RunningException怎么用?Java RunningException使用的例子?那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。



RunningException类属于com.esri.ges.core.component包,在下文中一共展示了RunningException类的14个代码示例,这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞,您的评价将有助于我们的系统推荐出更棒的Java代码示例。

示例1: start

import com.esri.ges.core.component.RunningException; //导入依赖的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


示例2: start

import com.esri.ges.core.component.RunningException; //导入依赖的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


示例3: start

import com.esri.ges.core.component.RunningException; //导入依赖的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


示例4: start

import com.esri.ges.core.component.RunningException; //导入依赖的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


示例5: start

import com.esri.ges.core.component.RunningException; //导入依赖的package包/类
public void start() throws RunningException {
	switch (getRunningState())
	{
	case STARTING:
	case STARTED:
		return;
	}

	setRunningState(RunningState.STARTING);
	thread = new Thread(this);
	thread.setPriority(thread.getPriority()+1);
	thread.start();

}
 
开发者ID:Esri,项目名称:defense-solutions-proofs-of-concept,代码行数:15,代码来源:TcpSquirtOutboundTransport.java


示例6: start

import com.esri.ges.core.component.RunningException; //导入依赖的package包/类
@Override
public void start() throws RunningException {
	switch (getRunningState())
	{
		case STARTING:
		case STARTED:
		case ERROR:
			return;
		default:
			// fall-through
			break;
	}

	setRunningState(RunningState.STARTING);
	setup();
	try {
		connectOBI();
		runThread = new WorkerThread();
		setRunningState(RunningState.STARTED);
		runThread.setName("InboundMLOBIFeatureServiceWorkerThread-"+ featureService + "-" + layerIndex);
		runThread.start();
		setErrorMessage(null);
	} catch (Exception e) {
		LOGGER.error(e.getMessage(), e);
	}
	
}
 
开发者ID:Esri,项目名称:defense-solutions-proofs-of-concept,代码行数:28,代码来源:MLOBIInboundTransport.java


示例7: start

import com.esri.ges.core.component.RunningException; //导入依赖的package包/类
@SuppressWarnings("incomplete-switch")
 public void start() throws RunningException
{
   switch (getRunningState())
	{
	case STARTING:
	case STARTED:
	case STOPPING:
		return;
	}
	setRunningState(RunningState.STARTING);
	applyProperties();
	/*
	 * ConnectionManager takes a Profile to use for new connections.
	 */
	manager = new ConnectionManager(new Profile(nickName));
	
	/*
	 * One instance of ConnectionManager can connect to many IRC networks.
	 * ConnectionManager#requestConnection(String) will return a Session object.
	 * The Session is the main way users will interact with this library and IRC
	 * networks
	 */
	Session session = manager.requestConnection(serverName);
	
	/*
	 * JerkLib fires IRCEvents to notify users of the lib of incoming events
	 * from a connected IRC server.
	 */
	session.addIRCEventListener(this);
}
 
开发者ID:Esri,项目名称:defense-solutions-proofs-of-concept,代码行数:32,代码来源:IrcInboundTransport.java


示例8: start

import com.esri.ges.core.component.RunningException; //导入依赖的package包/类
public void start() throws RunningException
{

 switch (getRunningState())
 {
 case STARTING:
 case STARTED:
 case STOPPING:
  return;
 }
 setRunningState(RunningState.STARTING);
 /*
  * ConnectionManager takes a Profile to use for new connections.
  */
 manager = new ConnectionManager(new Profile(nickName));

 /*
  * One instance of ConnectionManager can connect to many IRC networks.
  * ConnectionManager#requestConnection(String) will return a Session object.
  * The Session is the main way users will interact with this library and IRC
  * networks
  */
 Session session = manager.requestConnection(serverName);

 /*
  * JerkLib fires IRCEvents to notify users of the lib of incoming events
  * from a connected IRC server.
  */
 session.addIRCEventListener(this);
 applyProperties();
}
 
开发者ID:Esri,项目名称:defense-solutions-proofs-of-concept,代码行数:32,代码来源:IrcOutboundTransport.java


示例9: start

import com.esri.ges.core.component.RunningException; //导入依赖的package包/类
@SuppressWarnings("incomplete-switch")
public synchronized void start() throws RunningException {
  switch (getRunningState())
  {
    case STOPPING:
    case STOPPED:
    case ERROR:
      connect();
      break;
  }
}
 
开发者ID:Esri,项目名称:kafka-for-geoevent,代码行数:12,代码来源:KafkaOutboundTransport.java


示例10: start

import com.esri.ges.core.component.RunningException; //导入依赖的package包/类
@Override
public synchronized void start() throws RunningException {
  switch (getRunningState()) {
    case STOPPING:
    case STOPPED:
    case ERROR:
      connect();
      break;
  }
}
 
开发者ID:Esri,项目名称:kafka-for-geoevent,代码行数:11,代码来源:KafkaInboundTransport.java


示例11: start

import com.esri.ges.core.component.RunningException; //导入依赖的package包/类
@SuppressWarnings("incomplete-switch")
public synchronized void start() throws RunningException
{
	switch (getRunningState())
	{
		case STOPPING:
		case STOPPED:
		case ERROR:
			connect();
			break;
	}
}
 
开发者ID:Esri,项目名称:rabbitmq-for-geoevent,代码行数:13,代码来源:RabbitMQOutboundTransport.java


示例12: update

import com.esri.ges.core.component.RunningException; //导入依赖的package包/类
@Override
public void update(Observable observable, Object obj)
{
	if (obj instanceof RabbitMQTransportEvent)
	{
		RabbitMQTransportEvent event = (RabbitMQTransportEvent) obj;
		switch (event.getStatus())
		{
			case CREATED:
			case RECOVERY:
				try
				{
					start();
				}
				catch (RunningException e)
				{
					;
				}
				break;
			case DISCONNECTED:
				disconnect("");
				break;
			case SHUTDOWN:
				shutdown();
				break;
			case RECOVERY_FAILED:
			case CREATION_FAILED:
				LOGGER.error(event.getDetails());
				disconnect(event.getDetails());
				setRunningState(RunningState.ERROR);
				break;
			case RECOVERY_STARTED:
				break;
			case RECOVERY_COMPLETED:
				break;
			default:
				break;
		}
	}
}
 
开发者ID:Esri,项目名称:rabbitmq-for-geoevent,代码行数:41,代码来源:RabbitMQOutboundTransport.java


示例13: start

import com.esri.ges.core.component.RunningException; //导入依赖的package包/类
@SuppressWarnings("incomplete-switch")
@Override
public synchronized void start() throws RunningException
{
	switch (getRunningState())
	{
		case STOPPING:
		case STOPPED:
		case ERROR:
			connect();
			break;
	}
}
 
开发者ID:Esri,项目名称:rabbitmq-for-geoevent,代码行数:14,代码来源:RabbitMQInboundTransport.java


示例14: notifyInputs

import com.esri.ges.core.component.RunningException; //导入依赖的package包/类
private void notifyInputs(Stream input, String planFolder) throws PropertyException, RunningException
{
  TransportProxy tp = input.getTransportProxy();
  Transport t = tp.getProxiedTransport();
  
  input.stop();
  t.setProperty("inputDirectory", planFolder);
  input.start();

}
 
开发者ID:Esri,项目名称:route-monitor-for-geoevent,代码行数:11,代码来源:PlanManagerImpl.java



注:本文中的com.esri.ges.core.component.RunningException类示例整理自Github/MSDocs等源码及文档管理平台,相关代码片段筛选自各路编程大神贡献的开源项目,源码版权归原作者所有,传播和使用请参考对应项目的License;未经允许,请勿转载。


鲜花

握手

雷人

路过

鸡蛋
该文章已有0人参与评论

请发表评论

全部评论

专题导读
上一篇:
Java BootstrapServiceRegistryBuilder类代码示例发布时间:2022-05-22
下一篇:
Java Password类代码示例发布时间:2022-05-22
热门推荐
阅读排行榜

扫描微信二维码

查看手机版网站

随时了解更新最新资讯

139-2527-9053

在线客服(服务时间 9:00~18:00)

在线QQ客服
地址:深圳市南山区西丽大学城创智工业园
电邮:jeky_zhao#qq.com
移动电话:139-2527-9053

Powered by 互联科技 X3.4© 2001-2213 极客世界.|Sitemap