public class QuoteServer extends ReceiverAdapter
Any updates are multicast across the cluster
Constructor and Description |
---|
QuoteServer() |
Modifier and Type | Method and Description |
---|---|
java.util.Hashtable |
getAllStocks() |
float |
getQuote(java.lang.String stock_name) |
void |
getState(java.io.OutputStream ostream)
Allows an application to write a state through a provided OutputStream.
|
static void |
main(java.lang.String[] args) |
void |
printAllStocks() |
void |
setQuote(java.lang.String stock_name,
java.lang.Float value) |
void |
setState(java.io.InputStream istream)
Allows an application to read a state through a provided InputStream.
|
void |
start() |
void |
viewAccepted(View new_view)
Called when a change in membership has occurred.
|
block, receive, suspect, unblock
public void viewAccepted(View new_view)
ReceiverAdapter
Note that on reception of the first view (a new member just joined), the channel will not yet
be in the connected state. This only happens when Channel.connect(String)
returns.
viewAccepted
in interface MembershipListener
viewAccepted
in class ReceiverAdapter
public void start()
public float getQuote(java.lang.String stock_name) throws java.lang.Exception
java.lang.Exception
public void setQuote(java.lang.String stock_name, java.lang.Float value)
public java.util.Hashtable getAllStocks()
public void printAllStocks()
public void getState(java.io.OutputStream ostream) throws java.lang.Exception
ReceiverAdapter
getState
in interface MessageListener
getState
in class ReceiverAdapter
ostream
- the OutputStreamjava.lang.Exception
- if the streaming fails, any exceptions should be thrown so that the state requester
can re-throw them and let the caller know what happenedOutputStream.close()
public void setState(java.io.InputStream istream) throws java.lang.Exception
ReceiverAdapter
setState
in interface MessageListener
setState
in class ReceiverAdapter
istream
- the InputStreamjava.lang.Exception
- if the streaming fails, any exceptions should be thrown so that the state requester
can catch them and thus know what happenedInputStream.close()
public static void main(java.lang.String[] args)
Copyright © 1998-2020 Red Hat. All Rights Reserved.