`

Tibco RV Sample Listener

阅读更多

import org.apache.log4j.Logger;

import util.ConfigUtil;
import util.Constants;

import com.barcap.bondscape.monitor.PriceUpdateMonitor;
import com.tibco.tibrv.Tibrv;
import com.tibco.tibrv.TibrvDispatcher;
import com.tibco.tibrv.TibrvException;
import com.tibco.tibrv.TibrvListener;
import com.tibco.tibrv.TibrvMsg;
import com.tibco.tibrv.TibrvMsgCallback;
import com.tibco.tibrv.TibrvQueue;
import com.tibco.tibrv.TibrvRvdTransport;
import com.tibco.tibrv.TibrvTransport;


public class PriceListener implements TibrvMsgCallback, Constants
{
 Logger logger = Logger.getLogger(PriceListener.class);

 
 @Override
 public void onMsg(TibrvListener listener, TibrvMsg message)
 {
  try
  {
   if (message.get("ISIN") == null || message.get("RMDSSERVICE") == null || message.get("RICCODE") == null)
   {
    logger.error("ISIN or RMDSSERVICE or RICCODE is null");
    return;
   }
   String ricCode = message.get("ISIN").toString();
   String price = message.get("HOUSEPRICE").toString();
   logger.debug("ric:" + ricCode);
   logger.debug("housePrice:" + price);
  }
  catch (Exception e)
  {
   logger.error("exception while listening to prices" + e);
  }
 }
 
 public PriceListener()
 {
  String tibcoService = ConfigUtil.getValue(TIBCO_SERVICE);
  String tibcoNetwork = ConfigUtil.getValue(TIBCO_NETWORK);
  String tibcoDaemon = ConfigUtil.getValue(TIBCO_DAEMON);
  String tibcoSubject = ConfigUtil.getValue(TIBCO_SEND_SUBJECT);
  
  try
  {
   Tibrv.open(Tibrv.IMPL_NATIVE);
   TibrvTransport transport = new TibrvRvdTransport(tibcoService, tibcoNetwork, tibcoDaemon);
   TibrvQueue queue = new TibrvQueue();
   new TibrvListener(queue, this, transport, tibcoSubject, null);
   new TibrvDispatcher(queue);
   logger.debug("tibco rv connection successfully constructed!!");
  }
  catch (TibrvException e)
  {
   logger.error("Failed to start up price listener", e);
   System.exit(-1);
  }
 }
}

分享到:
评论

相关推荐

    TIBCO RV中间件rv.zip

    TIBCO RV(Rendezvous)是TIBCO软件公司推出的一种高效、可靠的实时消息传递中间件。它提供了一个强大的平台,使得应用程序之间能够通过消息传递进行通信,从而实现数据的共享和同步。TIBCO RV的核心特性在于其点对...

    tibco rv 发送与接收Demo

    在IT行业中,Tibco RV(Rendezvous)是一种广泛使用的中间件技术,它提供了可靠的、基于主题的消息传递服务。Tibco RV的核心是它的发布/订阅模型,它允许应用程序通过共享主题进行通信,无需知道彼此的存在。在这个...

    Tibco RV白皮书(官网)

    TIBCO RV(Rendezvous)是一种领先的消息传递产品,主要用于实现实时广泛数据分发应用程序,如市场数据、交易、电子商务、系统管理和实时控制系统。它被2000多家公司部署使用,是几个最大型、最关键系统的消息传递...

    TibcoRV_8.4.3.zip

    《Tibco RV 8.4.3:深入理解企业级消息传递系统》 Tibco RV(Tibco Rendezvous)是一款高效、可靠的企业级消息传递系统,广泛应用于分布式系统之间的通信。在8.4.3版本中,Tibco RV提供了全面的文档支持,包括管理...

    tibcorv代码

    《深入理解Tibcorv:基于代码的实践指南》 Tibcorv,全称TIBCO Rendezvous,是一款由TIBCO Software公司开发的高效、可靠的分布式消息传递系统。它提供了一种异步、面向发布/订阅的消息传递模式,广泛应用于企业级...

    TIBCO _RV中文java文档_.pdf

    本文档为TIBCO RV中文Java文档,提供了TIBCO RV Java参考软件版本8.4的详细信息。文档涵盖了软件的使用条款和条件、许可协议、版权信息、商标信息、软件功能、操作系统平台支持、技术 поддержка等方面。 ...

    TIBCO_RV__VS__IBM_MQ和JMS消息中间件的对比分析

    ### TIBCO Rendezvous (TIBCO RV) 与 IBM MQ 及 JMS 消息中间件的对比分析 #### TIBCO Rendezvous 技术简介 TIBCO Rendezvous(简称TIBCO RV)是一款强大的中间件产品,它通过一系列专有的技术,实现了异构系统...

    Tibco RV 7.5.4 版 32位元 安装包

    工业用通讯软体,利用广播技术, 在指定网域内广播 用tibrvlisten & tibrvsend的方式 接收与发送

    tibco_rv_concept

    ### Tibco Rendezvous (RV) 概念详解 #### 一、引言 Tibco Rendezvous(简称 RV)是 Tibco Software Inc. 开发的一款高性能消息传递中间件,它提供了一种灵活且可靠的方式,使得应用程序可以通过网络进行通信。...

    TIB_rv_dotnet_reference

    TIBCO Rendezvous(或称为TIBCO RV)产品是一种中间件,它具有发布/订阅(Publish/Subscribe)、基于主题寻址(Subject-Based Addressing) 和自定义数据信息(Self-Describing Data Messages)等专利技术功能,使不同应用...

    TIB_rv_8.5_dotnet_reference.pdf

    TIBCO Rendezvous .NET 参考指南 TIBCO Rendezvous 是一个基于(pub/sub)架构的消息中间件,用于实现分布式系统中的事件驱动编程。该产品提供了一个可靠、可扩展、可配置的消息队列系统,支持多种编程语言和平台。 ...

    几类中间件和对应的TIBCO产品介绍

    TIBCO(The Information Bus Company)是一家知名的中间件提供商,其产品线广泛,覆盖了多种类型的中间件解决方案。下面将详细阐述几类中间件以及TIBCO对应的拳头产品。 首先,我们来看看消息中间件。消息中间件,...

    tibrv Documnet

    TIBRV,全称为TIB/RV(TIBCO Rendezvous),是由TIBCO Software公司开发的一种高效、可靠的基于消息传递中间件(Message-Oriented Middleware,MOM)的技术。它允许应用程序通过网络进行异步通信,提供了一种松散...

    tib trainning material

    【标题】"TIB Trainning Material" 涵盖了TIBCO RV(Rendezvous)的内部培训内容,这是一套广泛应用于企业级分布式系统中的消息传递技术。TIBCO RV提供了高效、可靠的异步通信机制,允许应用程序在分布式环境中进行...

    关于TIBCO的学习资料3

    TIBCO Adapter™ Concepts

    通过C#窗体程序连接TIB/RV发送Message

    在窗体工具中输入实际Daemon信息发送RV Message到Rv服务器进行消息测试,程序主要是TIBCO.Rendezvous包send方法进行消息发送

    Tibco培训讲义

    TIBCO开发学习见解,有需要了解的可以下载看看 。介绍了里面的插件用法

    tib_rv_administration

    ### Tibco Rendezvous (RV/RVD) Administration详解 #### 一、引言 Tibco Rendezvous(简称RV或RVD)是一款强大的消息中间件软件,它为分布式应用程序提供了一个灵活、可靠且高性能的消息传递平台。RV/RVD不仅支持...

Global site tag (gtag.js) - Google Analytics