com.latencybusters.auxapi
Class UMEBlockSrc

java.lang.Object
  extended by com.latencybusters.auxapi.UMEBlockSrc

public class UMEBlockSrc
extends java.lang.Object


Field Summary
 LBMSource _src
           
 java.lang.Object appArg
           
 LBMSourceEventCallback appcb
           
 int err
           
 long first
           
 long last
           
 com.latencybusters.auxapi.UMEBitmap map
           
 java.util.concurrent.Semaphore stablelock
           
 
Constructor Summary
UMEBlockSrc()
           
 
Method Summary
 void close()
           
 boolean createSource(LBMContext lbmctx, LBMTopic lbmtopic, LBMSourceAttributes sattr, LBMSourceEventCallback cb, java.lang.Object cbArg, LBMEventQueue lbmevq)
           
 LBMContext getContext()
           
 LBMSource getSource()
           
 void send(byte[] message, int messagelength, int flags, LBMSourceSendExInfo exinfo)
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Field Detail

err

public int err

_src

public LBMSource _src

stablelock

public java.util.concurrent.Semaphore stablelock

appcb

public LBMSourceEventCallback appcb

appArg

public java.lang.Object appArg

map

public com.latencybusters.auxapi.UMEBitmap map

first

public long first

last

public long last
Constructor Detail

UMEBlockSrc

public UMEBlockSrc()
Method Detail

createSource

public boolean createSource(LBMContext lbmctx,
                            LBMTopic lbmtopic,
                            LBMSourceAttributes sattr,
                            LBMSourceEventCallback cb,
                            java.lang.Object cbArg,
                            LBMEventQueue lbmevq)
                     throws LBMException,
                            java.lang.InterruptedException
Throws:
LBMException
java.lang.InterruptedException

send

public void send(byte[] message,
                 int messagelength,
                 int flags,
                 LBMSourceSendExInfo exinfo)
          throws LBMException,
                 UMENoRegException,
                 java.lang.InterruptedException,
                 java.lang.Exception
Throws:
LBMException
UMENoRegException
java.lang.InterruptedException
java.lang.Exception

close

public void close()
           throws LBMException
Throws:
LBMException

getSource

public LBMSource getSource()

getContext

public LBMContext getContext()


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 29West Inc. Copyright © 2004-2014, Informatica, Inc. All Rights Reserved.