Package io.clonecloudstore.replicator.topic

Class LocalBrokerService

java.lang.Object

io.clonecloudstore.replicator.topic.LocalBrokerService

@ApplicationScoped
public class LocalBrokerService
extends Object

Constructor Summary

Constructors

Constructor	Description
LocalBrokerService(org.eclipse.microprofile.reactive.messaging.Emitter<ReplicatorOrder> replicatorOrderEmitter, BulkMetrics bulkMetrics)

Method Summary

Modifier and Type	Method	Description
void	createBucket(String bucket, String clientId)
void	createObject(String bucket, String object, String clientId, long size, String hash)
void	deleteBucket(String bucket, String clientId)
void	deleteObject(String bucket, String object, String clientId)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

LocalBrokerService

public LocalBrokerService(org.eclipse.microprofile.reactive.messaging.Emitter<ReplicatorOrder> replicatorOrderEmitter,
 BulkMetrics bulkMetrics)

Method Details

createBucket

public void createBucket(String bucket,
 String clientId)

deleteBucket

public void deleteBucket(String bucket,
 String clientId)

createObject

public void createObject(String bucket,
 String object,
 String clientId,
 long size,
 String hash)

deleteObject

public void deleteObject(String bucket,
 String object,
 String clientId)