org.sblim.slp.internal

Class MessageDispatcherStreamed


public class MessageDispatcherStreamed
extends java.lang.Object

MessageDispatcherStreamed.java (C) Copyright IBM Corp. 2005, 2006 THIS FILE IS PROVIDED UNDER THE TERMS OF THE COMMON PUBLIC LICENSE ("AGREEMENT"). ANY USE, REPRODUCTION OR DISTRIBUTION OF THIS FILE CONSTITUTES RECIPIENTS ACCEPTANCE OF THE AGREEMENT. You can obtain a current copy of the Common Public License from http://www.opensource.org/licenses/cpl1.0.php

Constructor Summary

MessageDispatcherStreamed(ServiceLocationMessage pRequest, Vector pResponseList, int[] pTimeoutList, int pMaxResults, InetAddress pInetAddress, boolean pJustFirstResult)

Method Summary

protected static boolean
addPreviousResponder(ServiceLocationMessage pRequest, InetAddress pInetAddress)
static ServiceLocationException
dispatchDAMsg(Vector pDAList, ServiceLocationMessage pRequest, Vector pResults, int pMaxReplies)
static ServiceLocationException
dispatchDatagramMsg(ServiceLocationMessage pRequest, Vector pResponseList, int[] pTimeoutList, int pMaxResults, InetAddress pInetAddress, boolean pJustFirstResult)
static Vector
dispatchMulticastMsg(InetAddress pInetAddress, DatagramSocket pDatagramSocket, ServiceLocationMessage pRequest, int[] pMsTimeOutsList, int pMaxResults, boolean getFirstResult)
static ServiceLocationMessage
dispatchStreamMsg(InetAddress pInetAddress, ServiceLocationMessage pRequest, boolean pRetry)
static Vector
dispatchUAMsg(Vector pDAList, ServiceLocationMessage pRequestMsg, InetAddress pInetAddress)
protected static byte[]
getBytes(ServiceLocationMessage pRequest, boolean pUsingMCast, boolean pUsingStreams)
ServiceLocationException
getExtendedError()
protected static ServiceLocationMessage
parseMsg(DataInputStream pInputStream)
void
run()

Constructor Details

MessageDispatcherStreamed

public MessageDispatcherStreamed(ServiceLocationMessage pRequest,
                                 Vector pResponseList,
                                 int[] pTimeoutList,
                                 int pMaxResults,
                                 InetAddress pInetAddress,
                                 boolean pJustFirstResult)

Method Details

addPreviousResponder

protected static boolean addPreviousResponder(ServiceLocationMessage pRequest,
                                              InetAddress pInetAddress)

dispatchDAMsg

public static ServiceLocationException dispatchDAMsg(Vector pDAList,
                                                     ServiceLocationMessage pRequest,
                                                     Vector pResults,
                                                     int pMaxReplies)

dispatchDatagramMsg

public static ServiceLocationException dispatchDatagramMsg(ServiceLocationMessage pRequest,
                                                           Vector pResponseList,
                                                           int[] pTimeoutList,
                                                           int pMaxResults,
                                                           InetAddress pInetAddress,
                                                           boolean pJustFirstResult)

dispatchMulticastMsg

public static Vector dispatchMulticastMsg(InetAddress pInetAddress,
                                          DatagramSocket pDatagramSocket,
                                          ServiceLocationMessage pRequest,
                                          int[] pMsTimeOutsList,
                                          int pMaxResults,
                                          boolean getFirstResult)
            throws ServiceLocationException

dispatchStreamMsg

public static ServiceLocationMessage dispatchStreamMsg(InetAddress pInetAddress,
                                                       ServiceLocationMessage pRequest,
                                                       boolean pRetry)
            throws ServiceLocationException

dispatchUAMsg

public static Vector dispatchUAMsg(Vector pDAList,
                                   ServiceLocationMessage pRequestMsg,
                                   InetAddress pInetAddress)
            throws ServiceLocationException

getBytes

protected static byte[] getBytes(ServiceLocationMessage pRequest,
                                 boolean pUsingMCast,
                                 boolean pUsingStreams)
            throws ServiceLocationException

getExtendedError

public ServiceLocationException getExtendedError()

parseMsg

protected static ServiceLocationMessage parseMsg(DataInputStream pInputStream)
            throws ServiceLocationException

run

public void run()

Copyright © 2005, 2006 IBM Corporation. All Rights Reserved.