Class: Gcpc::Interceptors::Subscriber::CheckDupInterceptor::BaseStrategy

Inherits:
Object
  • Object
show all
Defined in:
lib/gcpc/interceptors/subscriber/check_dup_interceptor.rb

Constant Summary collapse

DEFAULT_ID_KEY = 
"message_id"
DEFAULT_TTL =

7 days

7 * 24 * 3600

Instance Attribute Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize(ttl: DEFAULT_TTL, id_key: DEFAULT_ID_KEY) ⇒ BaseStrategy

Returns a new instance of BaseStrategy.



10
11
12
13
 
# File 'lib/gcpc/interceptors/subscriber/check_dup_interceptor.rb', line 10

def initialize(ttl: DEFAULT_TTL, id_key: DEFAULT_ID_KEY)
  @ttl    = ttl
  @id_key = id_key
end

Instance Attribute Details

#ttl ⇒ Object (readonly)

Returns the value of attribute ttl.



15
16
17
 
# File 'lib/gcpc/interceptors/subscriber/check_dup_interceptor.rb', line 15

def ttl
  @ttl
end

Instance Method Details

#id(data, attributes, message) ⇒ Object 



17
18
19
 
# File 'lib/gcpc/interceptors/subscriber/check_dup_interceptor.rb', line 17

def id(data, attributes, message)
  attributes[@id_key]
end

#on_dup(data, attributes, message, &block) ⇒ Object 



21
22
23
 
# File 'lib/gcpc/interceptors/subscriber/check_dup_interceptor.rb', line 21

def on_dup(data, attributes, message, &block)
  # Do nothing. Just ignore the duplicated message.
end