Overview  Package   Class  Tree  Deprecated  Index  Help 
 PREV CLASS   NEXT CLASS FRAMES    NO FRAMES    
SUMMARY: NESTED | FIELD | CONSTR | METHOD DETAIL: FIELD | CONSTR | METHOD

com.latencybusters.jms
Class LBMMessageProducer

java.lang.Object
  extended by com.latencybusters.jms.LBMMessageProducer
All Implemented Interfaces:
javax.jms.MessageProducer
Direct Known Subclasses:
LBMQueueSender, LBMTopicPublisher
public class LBMMessageProducer
extends java.lang.Object
implements javax.jms.MessageProducer

Field Summary
protected  LBMDestination dest
           
 
Constructor Summary
LBMMessageProducer()
           
LBMMessageProducer(LBMSession session, com.latencybusters.lbm.LBMContext myContext, com.latencybusters.lbm.LBMEventQueue evq, java.util.ArrayList<NameValue> props, LBMDestination dest, boolean transacted, java.lang.String cfName)
          This is an internal Method.
 
Method Summary
protected  void _send(javax.jms.Message message, LBMDestination destination)
           
 void close()
           
 void closeSources()
           
 void commit()
           
 com.latencybusters.lbm.LBMConfigOption[] dumpAttributeList(LBMDestination dest)
           
 int getDeliveryMode()
           
 LBMDestination getDestination()
           
 boolean getDisableMessageID()
           
 boolean getDisableMessageTimestamp()
           
 int getPriority()
           
protected  java.lang.Object getSource(LBMDestination destination, com.latencybusters.lbm.LBMContext myContext, com.latencybusters.lbm.LBMEventQueue evq, java.util.ArrayList<NameValue> props, boolean transacted, java.lang.String cfName)
           
 long getTimeToLive()
           
 boolean isOpen()
           
 void rollback()
           
 void send(javax.jms.Destination destination, javax.jms.Message message)
           
 void send(javax.jms.Destination destination, javax.jms.Message message, int deliveryMode, int priority, long timeToLive)
           
 void send(javax.jms.Message message)
           
 void send(javax.jms.Message message, int deliveryMode, int priority, long timeToLive)
           
 void setDeliveryMode(int deliveryMode)
           
 void setDisableMessageID(boolean value)
           
 void setDisableMessageTimestamp(boolean value)
           
protected  void setOptionalPrams(javax.jms.Message m)
           
 void setPriority(int priority)
           
 void setTimeToLive(long timeToLive)
           
 void start()
           
 void stop()
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Field Detail

dest

protected LBMDestination dest
Constructor Detail

LBMMessageProducer

public LBMMessageProducer()

LBMMessageProducer

public LBMMessageProducer(LBMSession session,
                          com.latencybusters.lbm.LBMContext myContext,
                          com.latencybusters.lbm.LBMEventQueue evq,
                          java.util.ArrayList<NameValue> props,
                          LBMDestination dest,
                          boolean transacted,
                          java.lang.String cfName)
                   throws javax.jms.JMSException
This is an internal Method.

Throws:
javax.jms.JMSException
Method Detail

getDestination

public LBMDestination getDestination()
                              throws javax.jms.JMSException
Specified by:
getDestination in interface javax.jms.MessageProducer
Throws:
javax.jms.JMSException

send

public void send(javax.jms.Destination destination,
                 javax.jms.Message message)
          throws javax.jms.JMSException
Specified by:
send in interface javax.jms.MessageProducer
Throws:
javax.jms.JMSException

send

public void send(javax.jms.Destination destination,
                 javax.jms.Message message,
                 int deliveryMode,
                 int priority,
                 long timeToLive)
          throws javax.jms.JMSException
Specified by:
send in interface javax.jms.MessageProducer
Throws:
javax.jms.JMSException

send

public void send(javax.jms.Message message)
          throws javax.jms.JMSException
Specified by:
send in interface javax.jms.MessageProducer
Throws:
javax.jms.JMSException

send

public void send(javax.jms.Message message,
                 int deliveryMode,
                 int priority,
                 long timeToLive)
          throws javax.jms.JMSException
Specified by:
send in interface javax.jms.MessageProducer
Throws:
javax.jms.JMSException

_send

protected void _send(javax.jms.Message message,
                     LBMDestination destination)
              throws javax.jms.JMSException
Throws:
javax.jms.JMSException

getSource

protected java.lang.Object getSource(LBMDestination destination,
                                     com.latencybusters.lbm.LBMContext myContext,
                                     com.latencybusters.lbm.LBMEventQueue evq,
                                     java.util.ArrayList<NameValue> props,
                                     boolean transacted,
                                     java.lang.String cfName)
                              throws javax.jms.JMSException
Throws:
javax.jms.JMSException

setOptionalPrams

protected void setOptionalPrams(javax.jms.Message m)
                         throws javax.jms.JMSException
Throws:
javax.jms.JMSException

close

public void close()
           throws javax.jms.JMSException
Specified by:
close in interface javax.jms.MessageProducer
Throws:
javax.jms.JMSException

closeSources

public void closeSources()
                  throws javax.jms.JMSException
Throws:
javax.jms.JMSException

start

public void start()

stop

public void stop()
          throws javax.jms.JMSException
Throws:
javax.jms.JMSException

commit

public void commit()

rollback

public void rollback()

getDeliveryMode

public int getDeliveryMode()
Specified by:
getDeliveryMode in interface javax.jms.MessageProducer

getDisableMessageID

public boolean getDisableMessageID()
Specified by:
getDisableMessageID in interface javax.jms.MessageProducer

getPriority

public int getPriority()
Specified by:
getPriority in interface javax.jms.MessageProducer

getTimeToLive

public long getTimeToLive()
Specified by:
getTimeToLive in interface javax.jms.MessageProducer

setDeliveryMode

public void setDeliveryMode(int deliveryMode)
Specified by:
setDeliveryMode in interface javax.jms.MessageProducer

setDisableMessageID

public void setDisableMessageID(boolean value)
Specified by:
setDisableMessageID in interface javax.jms.MessageProducer

setPriority

public void setPriority(int priority)
Specified by:
setPriority in interface javax.jms.MessageProducer

setTimeToLive

public void setTimeToLive(long timeToLive)
Specified by:
setTimeToLive in interface javax.jms.MessageProducer

getDisableMessageTimestamp

public boolean getDisableMessageTimestamp()
Specified by:
getDisableMessageTimestamp in interface javax.jms.MessageProducer

setDisableMessageTimestamp

public void setDisableMessageTimestamp(boolean value)
Specified by:
setDisableMessageTimestamp in interface javax.jms.MessageProducer

isOpen

public boolean isOpen()

dumpAttributeList

public com.latencybusters.lbm.LBMConfigOption[] dumpAttributeList(LBMDestination dest)
Overview  Package   Class  Tree  Deprecated  Index  Help 
 PREV CLASS   NEXT CLASS FRAMES    NO FRAMES    
SUMMARY: NESTED | FIELD | CONSTR | METHOD DETAIL: FIELD | CONSTR | METHOD
All of the documentation and software included in this and any other Informatica, Inc. "Ultra Messaging" Release is Copyright (C) 2004-2014, Informatica Corporation. All rights reserved. Redistribution and use in source and binary forms, with or without modification, are permitted only as covered by the terms of a valid software license agreement with Informatica Inc. Copyright © 2004-2014, Informatica, Inc. All Rights Reserved.