PubSubAccessor

java.lang.Object
- cz.o2.proxima.core.storage.AbstractStorage
- - cz.o2.proxima.core.storage.AbstractStorage.SerializableAbstractStorage
  - - cz.o2.proxima.direct.io.pubsub.PubSubAccessor

All Implemented Interfaces:

AbstractDataAccessor, DataAccessor, java.io.Serializable
```
public class PubSubAccessor
extends AbstractStorage.SerializableAbstractStorage
implements DataAccessor
```
A DataAccessor for Google PubSub.

See Also:

Serialized Form

Nested Class Summary
- Nested classes/interfaces inherited from class cz.o2.proxima.core.storage.AbstractStorage
  AbstractStorage.SerializableAbstractStorage

Field Summary

Fields
Modifier and Type	Field	Description
`static java.lang.String`	`CFG_MAX_ACK_DEADLINE`
`static java.lang.String`	`CFG_SUBSCRIPTION_ACK_DEADLINE`
`static java.lang.String`	`CFG_SUBSCRIPTION_AUTOCREATE`

Method Summary

All Methods Instance Methods Concrete Methods
Modifier and Type	Method	Description
`java.util.Optional<CommitLogReader>`	`getCommitLogReader(Context context)`	Retrieve commit log reader (if applicable).
`java.util.Optional<AttributeWriterBase>`	`getWriter(Context context)`	Retrieve writer (if applicable).
`boolean`	`isBulk()`

Methods inherited from class cz.o2.proxima.core.storage.AbstractStorage
equals, hashCode

Methods inherited from class java.lang.Object
clone, finalize, getClass, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface cz.o2.proxima.core.storage.internal.AbstractDataAccessor
getUri

Methods inherited from interface cz.o2.proxima.direct.core.DataAccessor
getBatchLogReader, getCachedView, getRandomAccessReader, isAcceptable

- Field Detail
  - CFG_MAX_ACK_DEADLINE
```
public static final java.lang.String CFG_MAX_ACK_DEADLINE
```
    See Also:
    
    Constant Field Values
  - CFG_SUBSCRIPTION_AUTOCREATE
```
public static final java.lang.String CFG_SUBSCRIPTION_AUTOCREATE
```
    See Also:
    
    Constant Field Values
  - CFG_SUBSCRIPTION_ACK_DEADLINE
```
public static final java.lang.String CFG_SUBSCRIPTION_ACK_DEADLINE
```
    See Also:
    
    Constant Field Values
- Method Detail
  - isBulk
```
public boolean isBulk()
```
  - getCommitLogReader
```
public java.util.Optional<CommitLogReader> getCommitLogReader(Context context)
```
    Description copied from interface: DataAccessor
    
    Retrieve commit log reader (if applicable).
    
    Specified by:
    
    getCommitLogReader in interface DataAccessor
    
    Parameters:
    
    context - serializable context provided by repository
    
    Returns:
    
    optional @{link CommitLogReader} of this accessor
  - getWriter
```
public java.util.Optional<AttributeWriterBase> getWriter(Context context)
```
    Description copied from interface: DataAccessor
    
    Retrieve writer (if applicable).
    
    Specified by:
    
    getWriter in interface DataAccessor
    
    Parameters:
    
    context - the serializable context provided by repository
    
    Returns:
    
    optional AttributeWriterBase of this accessor