com.crankuptheamps.client

Interface Subscription

All Known Implementing Classes:

LoggedBookmarkStore.Subscription, MemoryBookmarkStore.Subscription, RingBookmarkStore.Subscription

public interface Subscription

Interface that represents a single subscription within a bookmark store implementation. This can aid in creating your own implementation of BookmarkStore. If you feel that your requirements warrant creating a customized bookmark store implementation, please contact AMPS support for further advice.

 
 public static void main(String[] args) {

   try (HAClient client = new HAClient("subscribeExample");) {

      DefaultServerChooser sc = new DefaultServerChooser();
      sc.add(uri_);
      client.setServerChooser(sc);

      RingBookmarkStore bs = new RingBookmarkStore("bookmarks");
      client.setBookmarkStore(bs);

      client.connectAndLogon();

      // create the object to process the messages.
      BookmarkMessageHandler bmh = new BookmarkMessageHandler(client);

      System.out.println("... entering subscription ...");

      // Enter the subscription. This statement requests all
      // messages that have not been previously processed on the
      // "messages-history" topic.

      client.executeAsync( new Command(Message.Command.Subscribe)
                             .setTopic("messages-history")
                             .setSubId(new CommandId("sample-replay-id"))
                             .setBookmark(Client.Bookmarks.MOST_RECENT),
                          bmh);

      while (true)
      {
        Thread.sleep(100);
      }

    }
    catch (AMPSException e) {
      System.err.println(e.getLocalizedMessage());
      e.printStackTrace(System.err);
    }
 
 

Method Summary

Modifier and Type	Method and Description
void	discard(long index)
Field	getMostRecent()
Field	getMostRecentList(boolean useList)
long	getOldestBookmarkSeq()
BookmarkRangeField	getRange()
boolean	isDiscarded(BookmarkField bookmark)
long	log(BookmarkField bookmark)
void	setLastPersisted(BookmarkField bookmark)
void	setLastPersisted(long bookmark) Deprecated.
void	setResizeHandler(BookmarkStoreResizeHandler handler, BookmarkStore store)

Method Detail

log

long log(BookmarkField bookmark)
  throws java.io.IOException,
         CommandException

Throws:

java.io.IOException

CommandException

discard

void discard(long index)
      throws java.io.IOException

Throws:

java.io.IOException

isDiscarded

boolean isDiscarded(BookmarkField bookmark)
             throws java.io.IOException

Throws:

java.io.IOException

getMostRecent

Field getMostRecent()

getMostRecentList

Field getMostRecentList(boolean useList)

getRange

BookmarkRangeField getRange()

setLastPersisted

@Deprecated
void setLastPersisted(long bookmark)
                           throws java.io.IOException

Deprecated.

Throws:

java.io.IOException

setLastPersisted

void setLastPersisted(BookmarkField bookmark)
               throws java.io.IOException

Throws:

java.io.IOException

getOldestBookmarkSeq

long getOldestBookmarkSeq()

setResizeHandler

void setResizeHandler(BookmarkStoreResizeHandler handler,
                      BookmarkStore store)